本文整理了Java中org.I0Itec.zkclient.ZkClient.unsubscribeChildChanges()
方法的一些代码示例,展示了ZkClient.unsubscribeChildChanges()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkClient.unsubscribeChildChanges()
方法的具体详情如下:
包路径:org.I0Itec.zkclient.ZkClient
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!