作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.I0Itec.zkclient.ZkClient.unsubscribeAll()
方法的一些代码示例,展示了ZkClient.unsubscribeAll()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkClient.unsubscribeAll()
方法的具体详情如下:
包路径:org.I0Itec.zkclient.ZkClient
类名称:ZkClient
方法名:unsubscribeAll
暂无
代码示例来源:origin: com.hurence.logisland/logisland-agent
public void close() {
zkClient.unsubscribeAll();
}
代码示例来源:origin: beston123/Tarzan
@Override
public void shutdown(){
//取消所有订阅
zkClient.unsubscribeAll();
//关闭连接
zkClient.close();
LOGGER.info("close this connection to zookeeper {}.", zkAddress);
}
代码示例来源:origin: beston123/Tarzan
@Override
public void shutdown(){
//取消注册
unregisterAll();
//取消所有订阅
zkClient.unsubscribeAll();
//关闭连接
zkClient.close();
LOGGER.info("close this connection to zookeeper {}.", zkAddress);
}
代码示例来源:origin: zhuzhong/gateway-dubbox
private void runaway(final ZkClient zkClient, final String path) {
zkClient.unsubscribeAll();
ConcurrentHashMap<String, List<String>> newHosts = new ConcurrentHashMap<String, List<String>>();
zkClient.subscribeChildChanges(path, new IZkChildListener() {
代码示例来源:origin: youtongluan/sumk
@Override
public synchronized void stop() {
try {
ZkClient client = ZkClientHolder.getZkClient(zkUrl);
client.unsubscribeAll();
client.delete(path);
client.close();
} catch (Exception e) {
}
if (this.server != null) {
try {
this.server.stop();
} catch (IOException e) {
Log.printStack("sumk.rpc", e);
}
}
}
我是一名优秀的程序员,十分优秀!