Hello,

I have two queues and a few services that receive from one queue (call it
"inbox") process the data received, then sends the processed data to the
other queue (call it "outbox").  Is there a sane way using proton to fetch
the content of the message from the "inbox", process the data, send to the
"outbox", then ack the "inbox" so that the message can be permanently
removed?  And if it doesn't ack and the message consumer dies (or closes
its connection for some reason), the message becomes available in the
"inbox" again for another service to process

What I need to guard against is taking a message from "inbox" and the
service that took the message dies before it got a chance to send it's
processed data to the "outbox", loosing the message.  If the service dies,
I want the message it was working on to become available for another
service receiving from the same "inbox".

I've done this using qpid, but was hoping there is a way to do this using
proton. If not, is there some pattern that would achieve the same thing?

Thanks!

Reply via email to