本文整理了Java中com.github.zkclient.ZkClient.getChildren()
方法的一些代码示例,展示了ZkClient.getChildren()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkClient.getChildren()
方法的具体详情如下:
包路径:com.github.zkclient.ZkClient
类名称:ZkClient
方法名:getChildren
暂无
代码示例来源:origin: adyliu/jafka
/**
* get children nodes name
*
* @param zkClient zkClient
* @param path full path
* @return children nodes name or null while path not exist
*/
public static List<String> getChildrenParentMayNotExist(ZkClient zkClient, String path) {
try {
return zkClient.getChildren(path);
} catch (ZkNoNodeException e) {
return null;
}
}
代码示例来源:origin: adyliu/jafka
public void handleChildChange(String parentPath, List<String> currentChilds) throws Exception {
synchronized (lock) {
if (zkClient == null)
return;
try {
List<String> latestTopics = zkClient.getChildren(ZkUtils.BrokerTopicsPath);
logger.debug("all Topics: " + latestTopics);
eventHandler.handleTopicEvent(latestTopics);
} catch (ConsumerRebalanceFailedException e) {
logger.error("can't rebalance in embedded consumer); proceed to shutdown", e);
serverStartable.close();
} catch (Exception e) {
logger.error("error in handling child changes in embedded consumer", e);
}
}
}
}
代码示例来源:origin: com.github.adyliu/zkclient
@Override
public List<String> call() throws Exception {
exists(path, true);
try {
return getChildren(path, true);
} catch (ZkNoNodeException e) {
// ignore, the "exists" watch will listen for the parent node to appear
}
return null;
}
});
代码示例来源:origin: adyliu/zkclient
@Override
public List<String> call() throws Exception {
exists(path, true);
try {
return getChildren(path, true);
} catch (ZkNoNodeException e) {
// ignore, the "exists" watch will listen for the parent node to appear
}
return null;
}
});
代码示例来源:origin: adyliu/zkclient
public List<String> getChildren(String path) {
return getChildren(path, hasListeners(path));
}
代码示例来源:origin: com.github.adyliu/zkclient
public List<String> getChildren(String path) {
return getChildren(path, hasListeners(path));
}
代码示例来源:origin: com.github.adyliu/zkclient
public boolean deleteRecursive(String path) {
List<String> children;
try {
children = getChildren(path, false);
} catch (ZkNoNodeException e) {
return true;
}
if (children != null){
for (String subPath : children) {
if (!deleteRecursive(path + "/" + subPath)) {
return false;
}
}
}
return delete(path);
}
代码示例来源:origin: adyliu/zkclient
public boolean deleteRecursive(String path) {
List<String> children;
try {
children = getChildren(path, false);
} catch (ZkNoNodeException e) {
return true;
}
if (children != null){
for (String subPath : children) {
if (!deleteRecursive(path + "/" + subPath)) {
return false;
}
}
}
return delete(path);
}
代码示例来源:origin: com.github.adyliu/zkclient
@Override
public void run() throws Exception {
try {
// if the node doesn't exist we should listen for the root node to reappear
exists(path);
List<String> children = getChildren(path);
listener.handleChildChange(path, children);
} catch (ZkNoNodeException e) {
listener.handleChildChange(path, null);
}
}
});
代码示例来源:origin: adyliu/zkclient
@Override
public void run() throws Exception {
try {
// if the node doesn't exist we should listen for the root node to reappear
exists(path);
List<String> children = getChildren(path);
listener.handleChildChange(path, children);
} catch (ZkNoNodeException e) {
listener.handleChildChange(path, null);
}
}
});
内容来源于网络,如有侵权,请联系作者删除!