本文整理了Java中org.apache.activemq.leveldb.replicated.groups.ZKClient.waitForConnected()
方法的一些代码示例,展示了ZKClient.waitForConnected()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKClient.waitForConnected()
方法的具体详情如下:
包路径:org.apache.activemq.leveldb.replicated.groups.ZKClient
类名称:ZKClient
方法名:waitForConnected
暂无
代码示例来源:origin: org.apache.activemq/activemq-osgi
public void waitForConnected() throws InterruptedException, TimeoutException {
waitForConnected(null);
}
代码示例来源:origin: org.apache.activemq/activemq-leveldb-store
public void waitForConnected() throws InterruptedException, TimeoutException {
waitForConnected(null);
}
代码示例来源:origin: org.apache.activemq/activemq-all
public void waitForConnected() throws InterruptedException, TimeoutException {
waitForConnected(null);
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
protected IZooKeeper getZk() {
State state = _state;
if (state == State.NONE) {
throw new IllegalStateException("ZooKeeper client has not been configured yet. You need to either create an ensemble or join one.");
} else if (state != State.CONNECTED) {
try {
waitForConnected();
} catch (Exception e) {
throw new IllegalStateException("Error waiting for ZooKeeper connection", e);
}
}
IZooKeeper zk = _zk;
if (zk == null) {
throw new IllegalStateException("No ZooKeeper connection available");
}
return zk;
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
protected IZooKeeper getZk() {
State state = _state;
if (state == State.NONE) {
throw new IllegalStateException("ZooKeeper client has not been configured yet. You need to either create an ensemble or join one.");
} else if (state != State.CONNECTED) {
try {
waitForConnected();
} catch (Exception e) {
throw new IllegalStateException("Error waiting for ZooKeeper connection", e);
}
}
IZooKeeper zk = _zk;
if (zk == null) {
throw new IllegalStateException("No ZooKeeper connection available");
}
return zk;
}
代码示例来源:origin: org.apache.activemq/activemq-leveldb-store
@Override
protected IZooKeeper getZk() {
State state = _state;
if (state == State.NONE) {
throw new IllegalStateException("ZooKeeper client has not been configured yet. You need to either create an ensemble or join one.");
} else if (state != State.CONNECTED) {
try {
waitForConnected();
} catch (Exception e) {
throw new IllegalStateException("Error waiting for ZooKeeper connection", e);
}
}
IZooKeeper zk = _zk;
if (zk == null) {
throw new IllegalStateException("No ZooKeeper connection available");
}
return zk;
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
public void testGenerateConnectionLoss() throws Exception {
waitForConnected();
Object clientCnxnSocket = getField(_zk, "_zk", "cnxn", "sendThread", "clientCnxnSocket");
callMethod(clientCnxnSocket, "testableCloseSocket");
}
代码示例来源:origin: org.apache.activemq/activemq-all
public void testGenerateConnectionLoss() throws Exception {
waitForConnected();
Object clientCnxnSocket = getField(_zk, "_zk", "cnxn", "sendThread", "clientCnxnSocket");
callMethod(clientCnxnSocket, "testableCloseSocket");
}
代码示例来源:origin: org.apache.activemq/activemq-leveldb-store
public void testGenerateConnectionLoss() throws Exception {
waitForConnected();
Object clientCnxnSocket = getField(_zk, "_zk", "cnxn", "sendThread", "clientCnxnSocket");
callMethod(clientCnxnSocket, "testableCloseSocket");
}
代码示例来源:origin: org.apache.activemq/activemq-partition
protected void zkConnect() throws Exception {
zk_client = new ZKClient(plugin().getZkAddress(), Timespan.parse(plugin().getZkSessionTmeout()), null);
if( plugin().getZkPassword()!=null ) {
zk_client.setPassword(plugin().getZkPassword());
}
zk_client.start();
zk_client.waitForConnected(Timespan.parse("30s"));
}
内容来源于网络,如有侵权,请联系作者删除!