[rabbitmq-discuss] Consuming a Rollbacked Message
abbaspour_amin at yahoo.com
Sun Apr 26 12:43:17 BST 2009
In my Java client, I cannot receive a message after I rollbacked its previous transaction and entry is returned to queue.
I open a transactional channel:
channel = connection.createChannel();
consumer = new QueueingConsumer(channel);
And rollback like this:
but then this consumer does not receive anything from queue:
final QueueingConsumer.Delivery delivery = consumer.nextDelivery();
This is while I can see that I have the entry in queue (via rabbitmqctl list_queues) and consumer receives this entry after I restart the application.
What I can? Is there something wrong with my rollback or ACK mechanism? should I do something more than a simple txRollback()?
I use the latest client and server (1.5.4). Java client in Ubuntu server.
More information about the rabbitmq-discuss