Hi,
I have a requirement where:
1. One route reads data from the DB and posts the message to a Queue along with
the JMSXGroupId header set for EventSequencing
2. There are 3 consumers listening to the Queue with the CircuitBreaker
implementation as below:
<route id="consumer1">
<from uri="activemq:queue:test" />
<onException>
<exception>java.util.concurrent.RejectedExecutionException
</exception>
<handled>
<constant>false</constant>
</handled>
<bean ref="beanId" method="process" />
</onException>
<loadBalance>
<circuitBreaker threshold="3" halfOpenAfter="10000">
<exception>java.net.SocketException</exception>
<exception>org.apache.cxf.interceptor.Fault</exception>
<exception>java.lang.Exception</exception>
</circuitBreaker>
<to uri="direct-vm:someService" />
</loadBalance>
</route>
3. All three consumers are listening to the same queue.
4. Now let's say the direct-vm:someService is down, the message gets posted to
a DLQ.
5. But the sequence in which they arrived in the queue is now altered.
6. Moreover, the EventSequencing is also not working; as the same message is
getting picked up by all the three consumers.
Please help and let me know where I am going wrong.
Thanking in aniticpation
Best Regards
Shantanu Raizads
The information contained in this electronic message and any attachments to
this message are intended for the exclusive use of the addressee(s) and may
contain proprietary, confidential or privileged information. If you are not the
intended recipient, you should not disseminate, distribute or copy this e-mail.
Please notify the sender immediately and destroy all copies of this message and
any attachments. WARNING: Computer viruses can be transmitted via email. The
recipient should check this email and any attachments for the presence of
viruses. The company accepts no liability for any damage caused by any virus
transmitted by this email. www.wipro.com
