0
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 が切断されても、ビジネス コードは引き続き実行されます。

4

1 に答える 1