[rabbitmq-discuss] Transactions

Tue Jan 8 00:34:37 GMT 2013

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/20130107/99686f54/attachment.htm>