Skip to main content

Hi All, 

We are trying to leverage Transaction processing, while connecting to AMQP connector. Business requirement : If we have 100 messages, either send all 100 or nothing at all. We are using Try block- Always Begin with "Local" as transaction type. Inside, try we have for-each to transform messages and publish to AMQP with properties- Always join. We are getting below intermittent error:

Continuation call for method #method<tx.commit>() on channel AMQChannel(amqp://vHost@IPAddress:port/mulesoft,1) (#1) timed out

 

Can anyone throw a light on why we are getting this error and how to resolve it?

 

Thanks, Neeraj

0/9000