On 05/13/2011 11:21 AM, Ilyushonak Barys wrote:
Gordon, thanks again for detailed explanation.

2. I would like to cache qpid connection and session objects to increase 
producer performance.
Not sure what you mean here. You mean you want to avoid recreating a 
connection/session each time you need it?
You are right. I use infinite loop and in the loop I would like to avoid 
recreating a connection/session each time I need to send a message.

What would recovery consist of here for your case?
I got execution reports form the exchange and I would like to store message 
number exactly which was sent to the broker. In the error case I would like to 
redeliver messages from exchange starting exactly from the number I stored.

In general, if you lose your connection for example, you can't know exactly which message was the last the broker processed. You have a window of in-doubt messages (of size 1 to n, depending on you sender capacity).

That means you may get duplicates on redelivery. In the future we plane to offer richer functionality in this area. But for now only an at-least-once delivery is offered.

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:[email protected]

Reply via email to