LeaderSelectorListener listener = new LeaderSelectorListenerAdapter()
{
public void takeLeadership(CuratorFramework client) throws Exception
{
while (true) {
try {
// ... business logic
} catch (Exception e) { // catch any exeption here
// do nothing
}
}
}
}
LeaderSelector selector = new LeaderSelector(client, path, listener);
selector.autoRequeue();
selector.start();
コードが示すように、ビジネス コードで例外をキャッチしたので、Zookeeper が切断されても、ビジネス コードは引き続き実行されます。