This forum is now a read-only archive. All commenting, posting, registration services have been turned off. Those needing community support and/or wanting to ask questions should refer to the Tag/Forum map, and to http://spring.io/questions for a curated list of stackoverflow tags that Pivotal engineers, and the community, monitor.

AnnouncementAnnouncement Module

Collapse

No announcement yet.

Spring AMQP: would like to put message to queue and send ACK immediatelyPage Title Module

Spring AMQP: would like to put message to queue and send ACK immediately

Aug 14th, 2012, 07:36 AM

I wrote Java application, that sends messages to RabbitMQ. Then Flume picks messages up from RabbitMQ queue. I'm interested that nobody pulls messages from the queue, except flume.

My application uses Spring AMQP Java plugin.
The problem:

With the code below, message comes to RabbitMQ queue and stays 'Unknowledges' for ever. As I understand, RabbitMQ is waiting for ACK from MessageListener, but MessageListener will never ACK. Does anybody have idea how to fix it?