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

ZkClientx.unsubscribeDataChanges介绍

暂无

代码示例

代码示例来源：origin: alibaba/canal

public void stop() {
  super.stop();
  String path = ZookeeperPathUtils.getDestinationClientRunning(this.destination, clientData.getClientId());
  zkClient.unsubscribeDataChanges(path, dataListener);
  releaseRunning(); // 尝试一下release
  // Fix issue #697
  if (delayExector != null) {
    delayExector.shutdown();
  }
}

代码示例来源：origin: alibaba/canal

public synchronized void stop() {
  super.stop();
  if (zkClient != null) {
    String path = ZookeeperPathUtils.getDestinationServerRunning(destination);
    zkClient.unsubscribeDataChanges(path, dataListener);
    releaseRunning(); // 尝试一下release
  } else {
    processActiveExit(); // 没有zk，直接启动
  }
  processStop();
}

代码示例来源：origin: com.alibaba.otter/canal.client

public void stop() {
  super.stop();
  String path = ZookeeperPathUtils.getDestinationClientRunning(this.destination, clientData.getClientId());
  zkClient.unsubscribeDataChanges(path, dataListener);
  releaseRunning(); // 尝试一下release
  // Fix issue #697
  if (delayExector != null) {
    delayExector.shutdown();
  }
}