On 06/20/2010 06:36 AM, shailesh wrote:
I have an application built around a topic exchange.
( using the C++ API talking to a C++ qpid broker [0.6]  )

I need my application to be able to move a specific message between two
queues
i.e., I need a message to be "accepted" from Q1 and "published" to Q2,
ideally as a single "transaction" that can be committed or rolled back.

Can anyone suggest a method to achieve this using qpid 0.6 ?

Just call session.txSelect() to begin withm then subscribe to Q1, process messages from it by transferring them to Q2, acknowledge the message (or rely on auto-ack) and then call session.commit() to complete the atomic transfer. See cpp/src/tests/txtest.cpp in the 0.6 source tree for an example of this if you like.

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

Reply via email to