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

Broker.isStopped介绍

暂无

代码示例

代码示例来源：origin: apache/activemq

@Override
public boolean isStopped() {
  return getNext().isStopped();
}

代码示例来源：origin: apache/activemq

private boolean validateBroker(String host) {
    boolean result = true;
    if (BROKERS.containsKey(host) || SERVERS.containsKey(host) || CONNECTORS.containsKey(host)) {
      // check the broker is still in the BrokerRegistry
      TransportConnector connector = CONNECTORS.get(host);
      if (BrokerRegistry.getInstance().lookup(host) == null
        || (connector != null && connector.getBroker().isStopped())) {
        result = false;
        // clean-up
        BROKERS.remove(host);
        SERVERS.remove(host);
        if (connector != null) {
          CONNECTORS.remove(host);
          if (connector != null) {
            ServiceSupport.dispose(connector);
          }
        }
      }
    }
    return result;
  }
}

代码示例来源：origin: apache/activemq

if (!broker.isStopped()) {
  List<TransportConnectionState> connectionStates = listConnectionStates();
  connectionStates = listConnectionStates();

代码示例来源：origin: pierre/meteo

public boolean isStopped() {
  return next.isStopped();
}

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

@Override
public boolean isStopped() {
  return getNext().isStopped();
}

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

@Override
public boolean isStopped() {
  return getNext().isStopped();
}

代码示例来源：origin: pierre/meteo

public boolean isStopped() {
  return getNext().isStopped();
}

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

@Override
public boolean isStopped() {
  return getNext().isStopped();
}

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

private boolean validateBroker(String host) {
    boolean result = true;
    if (BROKERS.containsKey(host) || SERVERS.containsKey(host) || CONNECTORS.containsKey(host)) {
      // check the broker is still in the BrokerRegistry
      TransportConnector connector = CONNECTORS.get(host);
      if (BrokerRegistry.getInstance().lookup(host) == null
        || (connector != null && connector.getBroker().isStopped())) {
        result = false;
        // clean-up
        BROKERS.remove(host);
        SERVERS.remove(host);
        if (connector != null) {
          CONNECTORS.remove(host);
          if (connector != null) {
            ServiceSupport.dispose(connector);
          }
        }
      }
    }
    return result;
  }
}

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

private boolean validateBroker(String host) {
    boolean result = true;
    if (BROKERS.containsKey(host) || SERVERS.containsKey(host) || CONNECTORS.containsKey(host)) {
      // check the broker is still in the BrokerRegistry
      TransportConnector connector = CONNECTORS.get(host);
      if (BrokerRegistry.getInstance().lookup(host) == null
        || (connector != null && connector.getBroker().isStopped())) {
        result = false;
        // clean-up
        BROKERS.remove(host);
        SERVERS.remove(host);
        if (connector != null) {
          CONNECTORS.remove(host);
          if (connector != null) {
            ServiceSupport.dispose(connector);
          }
        }
      }
    }
    return result;
  }
}

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

private boolean validateBroker(String host) {
    boolean result = true;
    if (BROKERS.containsKey(host) || SERVERS.containsKey(host) || CONNECTORS.containsKey(host)) {
      // check the broker is still in the BrokerRegistry
      TransportConnector connector = CONNECTORS.get(host);
      if (BrokerRegistry.getInstance().lookup(host) == null
        || (connector != null && connector.getBroker().isStopped())) {
        result = false;
        // clean-up
        BROKERS.remove(host);
        SERVERS.remove(host);
        if (connector != null) {
          CONNECTORS.remove(host);
          if (connector != null) {
            ServiceSupport.dispose(connector);
          }
        }
      }
    }
    return result;
  }
}

代码示例来源：origin: pierre/meteo

private boolean validateBroker(String host) {
    boolean result = true;
    if (BROKERS.containsKey(host) || SERVERS.containsKey(host) || CONNECTORS.containsKey(host)) {
      // check the broker is still in the BrokerRegistry
      TransportConnector connector = CONNECTORS.get(host);
      if (BrokerRegistry.getInstance().lookup(host) == null
        || (connector != null && connector.getBroker().isStopped())) {
        result = false;
        // clean-up
        BROKERS.remove(host);
        SERVERS.remove(host);
        if (connector != null) {
          CONNECTORS.remove(host);
          if (connector != null) {
            ServiceSupport.dispose(connector);
          }
        }
      }
    }
    return result;
  }
}

代码示例来源：origin: pierre/meteo

if (!broker.isStopped()) {
  List<TransportConnectionState> connectionStates = listConnectionStates();
  connectionStates = listConnectionStates();

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

if (!broker.isStopped()) {
  List<TransportConnectionState> connectionStates = listConnectionStates();
  connectionStates = listConnectionStates();

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

if (!broker.isStopped()) {
  List<TransportConnectionState> connectionStates = listConnectionStates();
  connectionStates = listConnectionStates();

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

if (!broker.isStopped()) {
  List<TransportConnectionState> connectionStates = listConnectionStates();
  connectionStates = listConnectionStates();