Hi

I am trying to use the zookeeper route policy for failover and it does not work 
as I would expect. Here’s an example route.

ZooKeeperRoutePolicy policy = new 
ZooKeeperRoutePolicy("zookeeper://zookeeperHost/myapp/myroute", 1);
from("quartz2:start").routePolicy(policy).log(“hello world”);

I ran 2 instances of this application. 

The first instance displays “hello world” every second. This is behaving as the 
master as expected.

The second instance only displays "java.lang.IllegalStateException: Zookeeper 
based route policy prohibits processing exchanges, stopping route and failing 
the exchange”. There is nothing else after this. This is behaving as the slave 
as expected.

Now if I kill the first instance, I would expect the second instance to become 
the master and to display “hello world” every second. It doesn’t do this. It 
continues to display nothing. It appears as though the zookeeper route policy 
is not watching when it becomes the master and resuming the route.


Reply via email to