- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.griddynamics.jagger.coordinator.zookeeper.ZNode.removeWithChildren()
方法的一些代码示例,展示了ZNode.removeWithChildren()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZNode.removeWithChildren()
方法的具体详情如下:
包路径:com.griddynamics.jagger.coordinator.zookeeper.ZNode
类名称:ZNode
方法名:removeWithChildren
暂无
代码示例来源:origin: griddynamics/jagger
@Override
public void terminate() {
log.debug("termination signal received");
if(zooKeeperServer != null) {
try {
if (zoo != null) {
zoo.root().child(rootNode).removeWithChildren();
}
zooKeeperServer.shutdown();
} catch (Exception e) {
log.warn("Error during zookeeper termination. Message: {}", e.getMessage());
}
}
}
代码示例来源:origin: griddynamics/jagger
@Override
public void removeWithChildren() {
for (ZNode zNode : children()) {
zNode.removeWithChildren();
}
remove();
}
代码示例来源:origin: griddynamics/jagger
@Override
public void process(WatchedEvent event) {
log.debug("command {} execution done", command);
CommandExecutionResult result = outputNode.getObject(CommandExecutionResult.class);
switch (result.getStatus()) {
case SUCCEEDED:
log.debug("success");
callback.onSuccess((R) result.getResult());
break;
case FAILED:
Throwable e = result.getException();
log.error("fail", e);
callback.onFailure(e);
break;
default:
throw new IllegalStateException("Unknown status");
}
outputNode.removeWithChildren();
}
});
代码示例来源:origin: griddynamics/jagger
public void initialize() {
ZooKeeperFactory zooKeeperFactory = new ZooKeeperFactory();
zooKeeperFactory.setConnectString(endpoint);
zooKeeperFactory.setSessionTimeout(sessionTimeout);
log.info("Connect to {} endpoint with timeout {}", endpoint, sessionTimeout);
IZookeeper zooKeeper = null;
try {
zooKeeper = zooKeeperFactory.create();
zoo = new Zoo(zooKeeperFactory.create());
// TODO: timeout only 40000. svi.
if (zoo.root().hasChild(rootNode)) {
log.info("ZNode [" + rootNode + "] was found.");
zoo.root().child(rootNode).removeWithChildren();
log.info("ZNode [" + rootNode + "] with children nodes were removed.");
}
zoo.root().createChild(znode().withPath(rootNode));
log.info("ZNode [" + rootNode + "] was created.");
} finally {
if (zooKeeper != null) {
try {
zooKeeper.close();
} catch (InterruptedException e) {
// do nothing
}
}
}
}
代码示例来源:origin: griddynamics/jagger
typeNode.child(nodeContext.getId().getIdentifier()).removeWithChildren();
本文整理了Java中com.griddynamics.jagger.coordinator.zookeeper.ZNode类的一些代码示例,展示了ZNode类的具体用法。这些代码示例主要来源于Gith
本文整理了Java中com.griddynamics.jagger.coordinator.zookeeper.ZNodeParameters类的一些代码示例,展示了ZNodeParameters类的
本文整理了Java中com.griddynamics.jagger.coordinator.zookeeper.ZNodeParameters.withPath()方法的一些代码示例,展示了ZNode
本文整理了Java中com.griddynamics.jagger.coordinator.zookeeper.ZNode.child()方法的一些代码示例,展示了ZNode.child()的具体用法
本文整理了Java中com.griddynamics.jagger.coordinator.zookeeper.ZNode.removeWithChildren()方法的一些代码示例,展示了ZNode
本文整理了Java中com.griddynamics.jagger.coordinator.zookeeper.ZNode.hasChild()方法的一些代码示例,展示了ZNode.hasChild(
本文整理了Java中com.griddynamics.jagger.coordinator.zookeeper.ZNode.createChild()方法的一些代码示例,展示了ZNode.create
我是一名优秀的程序员,十分优秀!