本文整理了Java中org.apache.activemq.leveldb.replicated.groups.ZKClient.connect()方法的一些代码示例，展示了ZKClient.connect()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKClient.connect()方法的具体详情如下：
包路径：org.apache.activemq.leveldb.replicated.groups.ZKClient
类名称：ZKClient
方法名：connect

ZKClient.connect介绍

暂无

代码示例

代码示例来源：origin: org.apache.activemq/activemq-osgi

protected void doStart() throws InvalidSyntaxException, ConfigurationException, UnsupportedEncodingException {
  connect();
}

代码示例来源：origin: org.apache.activemq/activemq-all

protected void doStart() throws InvalidSyntaxException, ConfigurationException, UnsupportedEncodingException {
  connect();
}

代码示例来源：origin: org.apache.activemq/activemq-leveldb-store

protected void doStart() throws InvalidSyntaxException, ConfigurationException, UnsupportedEncodingException {
  connect();
}

代码示例来源：origin: org.apache.activemq/activemq-all

@Override
  public void run() {
    LOG.info("Entering recovery mode");
    synchronized(_lock) {
      try {
        int count = 0;
        while (_state == ZKClient.State.NONE) {
          try {
            count++;
            LOG.warn("Recovery mode: trying to reconnect to zookeeper [" + count + "]");
            ZKClient.this.connect();
          } catch (Throwable e) {
            LOG.warn("Recovery mode: reconnect attempt failed [" + count + "]... waiting for " + _reconnectTimeout, e);
            try {
              _lock.wait(_reconnectTimeout.getDurationInMilliseconds());
            } catch(InterruptedException e1) {
              throw new RuntimeException("Recovery mode: wait interrupted... bailing out", e1);
            }
          }
        }
      } finally {
        _expiredSessionRecovery = null;
        LOG.info("Exiting recovery mode.");
      }
    }
  }
}

代码示例来源：origin: org.apache.activemq/activemq-leveldb-store

@Override
  public void run() {
    LOG.info("Entering recovery mode");
    synchronized(_lock) {
      try {
        int count = 0;
        while (_state == ZKClient.State.NONE) {
          try {
            count++;
            LOG.warn("Recovery mode: trying to reconnect to zookeeper [" + count + "]");
            ZKClient.this.connect();
          } catch (Throwable e) {
            LOG.warn("Recovery mode: reconnect attempt failed [" + count + "]... waiting for " + _reconnectTimeout, e);
            try {
              _lock.wait(_reconnectTimeout.getDurationInMilliseconds());
            } catch(InterruptedException e1) {
              throw new RuntimeException("Recovery mode: wait interrupted... bailing out", e1);
            }
          }
        }
      } finally {
        _expiredSessionRecovery = null;
        LOG.info("Exiting recovery mode.");
      }
    }
  }
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

@Override
  public void run() {
    LOG.info("Entering recovery mode");
    synchronized(_lock) {
      try {
        int count = 0;
        while (_state == ZKClient.State.NONE) {
          try {
            count++;
            LOG.warn("Recovery mode: trying to reconnect to zookeeper [" + count + "]");
            ZKClient.this.connect();
          } catch (Throwable e) {
            LOG.warn("Recovery mode: reconnect attempt failed [" + count + "]... waiting for " + _reconnectTimeout, e);
            try {
              _lock.wait(_reconnectTimeout.getDurationInMilliseconds());
            } catch(InterruptedException e1) {
              throw new RuntimeException("Recovery mode: wait interrupted... bailing out", e1);
            }
          }
        }
      } finally {
        _expiredSessionRecovery = null;
        LOG.info("Exiting recovery mode.");
      }
    }
  }
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

protected void tryConnect() {
  synchronized (_lock) {
    try {
      connect();
    } catch (Throwable e) {
      LOG.warn("Error while restarting:", e);
      if (_expiredSessionRecovery == null) {
        _expiredSessionRecovery = new ExpiredSessionRecovery();
        _expiredSessionRecovery.setDaemon(true);
        _expiredSessionRecovery.start();
      }
    }
  }
}

代码示例来源：origin: org.apache.activemq/activemq-all

protected void tryConnect() {
  synchronized (_lock) {
    try {
      connect();
    } catch (Throwable e) {
      LOG.warn("Error while restarting:", e);
      if (_expiredSessionRecovery == null) {
        _expiredSessionRecovery = new ExpiredSessionRecovery();
        _expiredSessionRecovery.setDaemon(true);
        _expiredSessionRecovery.start();
      }
    }
  }
}

代码示例来源：origin: org.apache.activemq/activemq-leveldb-store

protected void tryConnect() {
  synchronized (_lock) {
    try {
      connect();
    } catch (Throwable e) {
      LOG.warn("Error while restarting:", e);
      if (_expiredSessionRecovery == null) {
        _expiredSessionRecovery = new ExpiredSessionRecovery();
        _expiredSessionRecovery.setDaemon(true);
        _expiredSessionRecovery.start();
      }
    }
  }
}