org.I0Itec.zkclient.ZkClient.unsubscribeChildChanges()方法的使用及代码示例

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

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

ZkClient.unsubscribeChildChanges介绍

暂无

代码示例

代码示例来源:origin: ltsopensource/light-task-scheduler

protected void removeTargetChildListener(String path, IZkChildListener iZkChildListener) {
  zkClient.unsubscribeChildChanges(path, iZkChildListener);
}

代码示例来源:origin: ltsopensource/light-task-scheduler

protected void removeTargetChildListener(String path, IZkChildListener iZkChildListener) {
  zkClient.unsubscribeChildChanges(path, iZkChildListener);
}

代码示例来源:origin: networknt/light-4j

@Override
public void unsubscribeChildChanges(String path, IZkChildListener childListener) {
  zkClient.unsubscribeChildChanges(path, childListener);
}

代码示例来源:origin: apache/incubator-dubbo

public void unsubscribeChildChanges(String path, IZkChildListener listener) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.unsubscribeChildChanges(path, listener);
}

代码示例来源:origin: apache/incubator-dubbo

public void unsubscribeChildChanges(String path, IZkChildListener listener) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.unsubscribeChildChanges(path, listener);
}

代码示例来源:origin: weibocom/motan

@Override
protected void unsubscribeService(URL url, ServiceListener serviceListener) {
  try {
    clientLock.lock();
    Map<ServiceListener, IZkChildListener> childChangeListeners = serviceListeners.get(url);
    if (childChangeListeners != null) {
      IZkChildListener zkChildListener = childChangeListeners.get(serviceListener);
      if (zkChildListener != null) {
        zkClient.unsubscribeChildChanges(ZkUtils.toNodeTypePath(url, ZkNodeType.CLIENT), zkChildListener);
        childChangeListeners.remove(serviceListener);
      }
    }
  } catch (Throwable e) {
    throw new MotanFrameworkException(String.format("Failed to unsubscribe service %s to zookeeper(%s), cause: %s", url, getUrl(), e.getMessage()), e);
  } finally {
    clientLock.unlock();
  }
}

代码示例来源:origin: uber/chaperone

public void stop() {
 _zkClient.unsubscribeChildChanges(KAFKA_TOPICS_PATH, this);
 executorService.shutdown();
}

代码示例来源:origin: javahongxi/whatsmars

public void unsubscribeChildChanges(String path, IZkChildListener listener) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.unsubscribeChildChanges(path, listener);
}

代码示例来源:origin: hutai123/dubbox

public void removeTargetChildListener(String path, IZkChildListener listener) {
  client.unsubscribeChildChanges(path,  listener);
}

代码示例来源:origin: jobxhub/JobX

public void removeTargetChildListener(String path, IZkChildListener listener) {
  client.unsubscribeChildChanges(path, listener);
}

代码示例来源:origin: apache/samza

public void unsubscribeChildChanges(String path, IZkChildListener childListener) {
 zkClient.unsubscribeChildChanges(path, childListener);
}

代码示例来源:origin: com.github.ltsopensource/lts-core

protected void removeTargetChildListener(String path, IZkChildListener iZkChildListener) {
  zkClient.unsubscribeChildChanges(path, iZkChildListener);
}

代码示例来源:origin: hutai123/dubbox

public void removeTargetChildListener(String path, IZkChildListener listener) {
  client.unsubscribeChildChanges(path,  listener);
}

代码示例来源:origin: org.apache.samza/samza-core_2.10

public void unsubscribeChildChanges(String path, IZkChildListener childListener) {
 zkClient.unsubscribeChildChanges(path, childListener);
}

代码示例来源:origin: org.apache.samza/samza-core

public void unsubscribeChildChanges(String path, IZkChildListener childListener) {
 zkClient.unsubscribeChildChanges(path, childListener);
}

代码示例来源:origin: com.taobao.metamorphosis/metamorphosis-client

void dispose() {
  final String partitionPath = ProducerZooKeeper.this.metaZookeeper.brokerTopicsPubPath + "/" + this.topic;
  ProducerZooKeeper.this.zkClient.unsubscribeChildChanges(partitionPath, this);
}

代码示例来源:origin: uber/uReplicator

public void stop() {
 _zkClient.unsubscribeChildChanges(KAFKA_TOPICS_PATH, this);
 executorService.shutdown();
}

代码示例来源:origin: uber/uReplicator

public void stop() {
 _zkClient.unsubscribeChildChanges(KAFKA_TOPICS_PATH, this);
 executorService.shutdown();
}

代码示例来源:origin: com.alibaba/dubbo-remoting-zookeeper

public void unsubscribeChildChanges(String path, IZkChildListener listener) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.unsubscribeChildChanges(path, listener);
}

代码示例来源:origin: com.alibaba/dubbo

public void unsubscribeChildChanges(String path, IZkChildListener listener) {
  Assert.notNull(client, new IllegalStateException("Zookeeper is not connected yet!"));
  client.unsubscribeChildChanges(path, listener);
}

相关文章