com.alibaba.wasp.zookeeper.ZooKeeperWatcher.close()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(1.5k)|赞(0)|评价(0)|浏览(71)

本文整理了Java中com.alibaba.wasp.zookeeper.ZooKeeperWatcher.close()方法的一些代码示例,展示了ZooKeeperWatcher.close()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperWatcher.close()方法的具体详情如下:
包路径:com.alibaba.wasp.zookeeper.ZooKeeperWatcher
类名称:ZooKeeperWatcher
方法名:close

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();

相关文章