Camel Zookeeper Route Policy

[Saikat Kar <sa...@gmail.com>]

Hi,

  I am using apache camel routes for message processing.I am using apache
camel zookeeper route policy to provide fail over and HA to the camel
routes.I have externalized quorum of zookeeper server to which the
zookeeper clients connect.The camel version I are using is 2.12.1.
 But whenever I are trying to run the route instances more than what I have
provided in the ZookeeperRoutePolicy() constructor I are facing this
scenario.
 say,
 the enabledCount in the ZooKeeperRoutePolicy() is 1 and i am trying to
start two camel route instances
 The first route instance is running well.But the 2nd instacne is getting
this exception

 java.lang.IllegalStateException: Zookeeper based route policy prohibits
processing exchanges, stopping route and failing the exchange
at
org.apache.camel.component.zookeeper.policy.ZooKeeperRoutePolicy.onExchangeBegin(ZooKeeperRoutePolicy.java:87)
at
org.apache.camel.processor.CamelInternalProcessor$RoutePolicyAdvice.before(CamelInternalProcessor.java:443)
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:139)
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:103)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:562)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:500)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:468)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:243)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1103)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:997)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
The cause of this error is unknown to me.Please shed some light on this
regard

thanks & regards
Saikat Kar