Skip to main content

Hi Guys,

I'm having a flow that is triggered with a message from an AMQP inbound and once the message is received I'm performing few validations using expression component on the inbound message and trying to insert the payload in the DB.

An happy path scenario works fine I'm able to insert the record and acknowledge the inbound channel, when I receive any error in the DB insert or after the DB insert I'm able to re-queue or use some backout strategy to get the message and not loose it .

When a fatal error occurs before the DB insert like server went down, I'm able to see the message in the inbound queue, But I'm loosing the message while fatal error occurs on DB insert or after DB insert.

I tried to use either multi transaction or xa-transaction seems like AMQP doesn't support it. Can some one help me on this and how to prevent loosing the message.

 

Thanks

0/9000