本文整理了Java中com.alibaba.wasp.zookeeper.ZooKeeperWatcher.close()
方法的一些代码示例,展示了ZooKeeperWatcher.close()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperWatcher.close()
方法的具体详情如下:
包路径:com.alibaba.wasp.zookeeper.ZooKeeperWatcher
类名称:ZooKeeperWatcher
方法名:close
[英]Close the connection to ZooKeeper.
[中]关闭与ZooKeeper的连接。
代码示例来源:origin: alibaba/wasp
void internalClose() {
super.close();
}
}
代码示例来源:origin: alibaba/wasp
private synchronized void resetZooKeeperTrackers() {
if (masterAddressTracker != null) {
masterAddressTracker.stop();
masterAddressTracker = null;
}
clusterId = null;
if (zooKeeper != null) {
zooKeeper.close();
zooKeeper = null;
}
}
代码示例来源:origin: alibaba/wasp
/**
* @see java.io.Closeable#close()
*/
@Override
public void close() throws IOException {
if (this.closed) {
return;
}
for (FClientCallable callable : callables.values()) {
callable.close();
}
fserverTracker = null;
zooKeeper.close();
if (this.connection != null) {
this.connection.close();
}
this.closed = true;
}
代码示例来源:origin: alibaba/wasp
@After
public void after() throws KeeperException {
if (this.watcher != null) {
// Clean up all znodes
ZKAssign.deleteAllNodes(this.watcher);
this.watcher.close();
}
}
代码示例来源:origin: alibaba/wasp
} finally {
if (zkw != null) {
zkw.close();
代码示例来源:origin: alibaba/wasp
this.zooKeeper.close();
LOG.info("stopping server " + this.serverNameFromMasterPOV
+ "; zookeeper connection closed.");
代码示例来源:origin: alibaba/wasp
if (this.assignmentManager != null)
this.assignmentManager.stop();
this.zooKeeper.close();
内容来源于网络,如有侵权,请联系作者删除!