[rabbitmq-discuss] Transactions

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>