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

ZKClient.changeState介绍

暂无

代码示例

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

public void process(WatchedEvent event) {
  if (event.getState() != null) {
    LOG.debug("event: {}", event.getState());
    synchronized (_lock) {
      switch(event.getState())
      {
        case SyncConnected:
          changeState(State.CONNECTED);
          break;
        case Disconnected:
          if(_state != State.NONE) {
            changeState(State.RECONNECTING);
          }
          break;
        case Expired:
          // when expired, the zookeeper object is invalid and we need to recreate a new one
          _zk = null;
          LOG.warn("Expiration detected: trying to restart...");
          tryConnect();
          break;
        default:
          LOG.warn("unprocessed event state: {}", event.getState());
      }
    }
  }
}

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

public void process(WatchedEvent event) {
  if (event.getState() != null) {
    LOG.debug("event: {}", event.getState());
    synchronized (_lock) {
      switch(event.getState())
      {
        case SyncConnected:
          changeState(State.CONNECTED);
          break;
        case Disconnected:
          if(_state != State.NONE) {
            changeState(State.RECONNECTING);
          }
          break;
        case Expired:
          // when expired, the zookeeper object is invalid and we need to recreate a new one
          _zk = null;
          LOG.warn("Expiration detected: trying to restart...");
          tryConnect();
          break;
        default:
          LOG.warn("unprocessed event state: {}", event.getState());
      }
    }
  }
}

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

public void process(WatchedEvent event) {
  if (event.getState() != null) {
    LOG.debug("event: {}", event.getState());
    synchronized (_lock) {
      switch(event.getState())
      {
        case SyncConnected:
          changeState(State.CONNECTED);
          break;
        case Disconnected:
          if(_state != State.NONE) {
            changeState(State.RECONNECTING);
          }
          break;
        case Expired:
          // when expired, the zookeeper object is invalid and we need to recreate a new one
          _zk = null;
          LOG.warn("Expiration detected: trying to restart...");
          tryConnect();
          break;
        default:
          LOG.warn("unprocessed event state: {}", event.getState());
      }
    }
  }
}

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

public void connect() throws UnsupportedEncodingException {
  synchronized (_lock) {
    changeState(State.CONNECTING);
    _zk = _factory.createZooKeeper(this);
    if (password != null) {
      _zk.addAuthInfo("digest", ("fabric:" + password).getBytes("UTF-8"));
    }
  }
}

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

public void connect() throws UnsupportedEncodingException {
  synchronized (_lock) {
    changeState(State.CONNECTING);
    _zk = _factory.createZooKeeper(this);
    if (password != null) {
      _zk.addAuthInfo("digest", ("fabric:" + password).getBytes("UTF-8"));
    }
  }
}

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

public void connect() throws UnsupportedEncodingException {
  synchronized (_lock) {
    changeState(State.CONNECTING);
    _zk = _factory.createZooKeeper(this);
    if (password != null) {
      _zk.addAuthInfo("digest", ("fabric:" + password).getBytes("UTF-8"));
    }
  }
}

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

if (_zk != null) {
  try {
    changeState(State.NONE);
    _zk.close();

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

if (_zk != null) {
  try {
    changeState(State.NONE);
    _zk.close();

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

if (_zk != null) {
  try {
    changeState(State.NONE);
    _zk.close();