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.1
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase of over 48,000 articles and solutions.
Welcome! Check out the Getting Started with Red Hat page for quick tours and guides for common tasks.
