[rabbitmq-discuss] Transactions

CJ rmqjava1a at yahoo.com
Tue Jan 8 21:39:37 GMT 2013

This is working correctly now.
I switched to autoAck = false and wrote my own basicAct, and now everything 
works very well

On Monday, January 7, 2013 7:34:37 PM UTC-5, CJ wrote:

> I am trying to figure out Rabbit Tx's
> My producer sends 100 Persistent TX and dies as I directed.
> Than I run a consumer that reads the messages from the durable Q with a 
> txcommit after the reception
> Then my receiver can consume all 100 messages, and does so.
> I am happy with this result, so I start over 
> ......
> I have my producer send another 100 messages.
> But this time I have the consumer only read 50 persistent messages with a 
> txcommit.
> I read in all of the first 50 messages correctly.
> So I run the consumer again, hoping to get the next 50, but this time it 
> does not see any persistent Tx on the Q, and receive zero messages
> What it looks like is that when the receiver opens the channel, Rabbit 
> sends a batch of messages from the database and the consumer can open them 
> one by one, and if the receiver closes the channel before the batch 
> processing of all the records has completed, those messages will be lost 
> regardless of whether they are persistent or not., and therefore I have to 
> take that into account when I write my consumers.  Is this a correct 
> assumption, or did I make a mistake ?
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130108/40cffb45/attachment.htm>

More information about the rabbitmq-discuss mailing list