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.