|
|
|
@ -55,7 +55,7 @@ public class ZookeeperOperator implements InitializingBean {
|
|
|
|
|
@Override |
|
|
|
|
public void afterPropertiesSet() throws Exception { |
|
|
|
|
this.zkClient = buildClient(); |
|
|
|
|
initStateLister(); |
|
|
|
|
initStateListener(); |
|
|
|
|
treeCacheStart(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -66,7 +66,7 @@ public class ZookeeperOperator implements InitializingBean {
|
|
|
|
|
|
|
|
|
|
protected void treeCacheStart(){} |
|
|
|
|
|
|
|
|
|
public void initStateLister() { |
|
|
|
|
public void initStateListener() { |
|
|
|
|
checkNotNull(zkClient); |
|
|
|
|
|
|
|
|
|
zkClient.getConnectionStateListenable().addListener((client, newState) -> { |
|
|
|
|