- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.<init>()
方法的一些代码示例,展示了ZooKeeperImpl.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperImpl.<init>()
方法的具体详情如下:
包路径:com.ngdata.sep.util.zookeeper.ZooKeeperImpl
类名称:ZooKeeperImpl
方法名:<init>
暂无
代码示例来源:origin: NGDATA/hbase-indexer
public static ZooKeeperItf connect(String connectString, int sessionTimeout) throws ZkConnectException {
ZooKeeperImpl zooKeeper;
try {
zooKeeper = new ZooKeeperImpl(connectString, sessionTimeout);
} catch (IOException e) {
throw new ZkConnectException("Failed to connect with Zookeeper @ '" + connectString + "'", e);
}
long waitUntil = System.currentTimeMillis() + sessionTimeout;
boolean connected = (States.CONNECTED).equals(zooKeeper.getState());
while (!connected && waitUntil > System.currentTimeMillis()) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
connected = (States.CONNECTED).equals(zooKeeper.getState());
break;
}
connected = (States.CONNECTED).equals(zooKeeper.getState());
}
if (!connected) {
System.out.println("Failed to connect to Zookeeper within timeout: Dumping stack: ");
Thread.dumpStack();
zooKeeper.close();
throw new ZkConnectException("Failed to connect with Zookeeper @ '" + connectString +
"' within timeout " + sessionTimeout);
}
return zooKeeper;
}
代码示例来源:origin: com.ngdata/hbase-sep-impl-common
public static ZooKeeperItf connect(String connectString, int sessionTimeout) throws ZkConnectException {
ZooKeeperImpl zooKeeper;
try {
zooKeeper = new ZooKeeperImpl(connectString, sessionTimeout, new DefaultACLProvider());
} catch (IOException e) {
throw new ZkConnectException("Failed to connect with Zookeeper @ '" + connectString + "'", e);
}
long waitUntil = System.currentTimeMillis() + sessionTimeout;
boolean connected = (States.CONNECTED).equals(zooKeeper.getState());
while (!connected && waitUntil > System.currentTimeMillis()) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
connected = (States.CONNECTED).equals(zooKeeper.getState());
break;
}
connected = (States.CONNECTED).equals(zooKeeper.getState());
}
if (!connected) {
System.out.println("Failed to connect to Zookeeper within timeout: Dumping stack: ");
Thread.dumpStack();
zooKeeper.close();
throw new ZkConnectException("Failed to connect with Zookeeper @ '" + connectString +
"' within timeout " + sessionTimeout);
}
return zooKeeper;
}
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.getState()方法的一些代码示例,展示了ZooKeeperImpl.getState(
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.isCurrentThreadEventThread()方法的一些代码示例,展示了ZooKe
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.close()方法的一些代码示例,展示了ZooKeeperImpl.close()的具体用法
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.()方法的一些代码示例,展示了ZooKeeperImpl.()的具体用法。这些代码示例主要来
本文整理了Java中com.ngdata.sep.util.zookeeper.ZooKeeperImpl.waitForConnection()方法的一些代码示例,展示了ZooKeeperImpl.
我是一名优秀的程序员,十分优秀!