CorrelationID not matching in case of Fuse Ensemble and ActiveMQ master Slave Setup
Issue
We have 3 node architecture with Fuse Ensemble setup. We have A-MQ running in Master - Slave configuration. When we place the message from node 1 to A-MQ, it times out waiting for the response from the reply to queue.
Timeout occurred after 20000 millis waiting for reply message with correlationID [Camel-ID-xxx-xxx-57270-1339232420004-8-4]. Setting ExchangeTimedOutException on (MessageId: Camel-ID-xxx-xxx-57270-1339232420004-8-1 on ExchangeId: Camel-ID-xxx-xxx-57270-1339232420004-8-2) and continue routing.
It is observed that the response is received on a different node where this correlation id is not expected:
Reply received for unknown correlationID [Camel-ID-xxx-xxx-57270-1339232420004-8-4] on reply destination [queue://EndpointReply]. Current correlation map size: 0. The message will be ignored
...
ActiveMQ message is put with the below URL:
activemq:EndpointQueue?replyToType=Exclusive&replyTo=EndpointReply
Environment
- JBoss Fuse/A-MQ 6.x
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.