Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
MIME-Version: 1.0
From: Shantanu Raizada <shantanu.raizada91@gmail.com>
Date: Wed, 18 Jan 2017 15:36:43 +0530
Message-ID: <CAHGAw1TYhFocV-R9+w3ZWn22JQfiSbzwvWbd93nxXnCKjpUvgQ@mail.gmail.com>
Subject: Very Urgent: Combining EventSequencing and CircuitBreaker in AMQ
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=001a11410858e4cb0705465b9261
archived-at: Wed, 18 Jan 2017 10:42:57 -0000

--001a11410858e4cb0705465b9261
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

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=3D=E2=80=9Dconsumer1=E2=80=9D>

<from uri=3D"activemq:queue:test" />

              <onException>


<exception>java.util.concurrent.RejectedExecutionException

                           </exception>

                           <handled>

                                  <constant>false</constant>

                           </handled>

                           <bean ref=3D"beanId" method=3D"process" />

                     </onException>

       <loadBalance>

                           <circuitBreaker threshold=3D"3"
halfOpenAfter=3D"10000">


<exception>java.net.SocketException</exception>


<exception>org.apache.cxf.interceptor.Fault</exception>


 <exception>java.lang.Exception</exception>

                           </circuitBreaker>

                           <to uri=3D"direct-vm:someService" />

                     </loadBalance>

              </route>


3. All three consumers are listening to the same queue.

4. Now let=E2=80=99s say the *direct-vm:someService* is down, the message g=
ets
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

--001a11410858e4cb0705465b9261--