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
> 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...
More information about the rabbitmq-discuss