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

Broker.getBrokerId介绍

[英]Get the id of the broker
[中]获取代理的id

代码示例

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

@Override
public void setBrokerService(BrokerService brokerService) {
  this.brokerService = brokerService;
  this.localBrokerId = brokerService.getRegionBroker().getBrokerId();
  localBrokerPath[0] = localBrokerId;
}

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

@Override
public BrokerId getBrokerId() {
  return getNext().getBrokerId();
}

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

/**
 * @return the unique id of the Broker
 */
public String getBrokerId(){
  try {
    return brokerService.getBroker().getBrokerId().toString();
  } catch (Exception e) {
    return "";
  }
}

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

brokerId = broker.getBrokerId();

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

broker = brokerService.getBroker();
brokerInfo.setBrokerName(broker.getBrokerName());
brokerInfo.setBrokerId(broker.getBrokerId());
brokerInfo.setPeerBrokerInfos(broker.getPeerBrokerInfos());
brokerInfo.setFaultTolerantConfiguration(broker.isFaultTolerantConfiguration());

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

protected ActiveMQMapMessage prepareSubscriptionMessage(SubscriptionViewMBean subscriber) throws JMSException {
  Broker regionBroker = getBrokerService().getRegionBroker();
  ActiveMQMapMessage statsMessage = new ActiveMQMapMessage();
  statsMessage.setString("brokerName", regionBroker.getBrokerName());
  statsMessage.setString("brokerId", regionBroker.getBrokerId().toString());
  statsMessage.setString("destinationName", subscriber.getDestinationName());
  statsMessage.setString("clientId", subscriber.getClientId());
  statsMessage.setString("connectionId", subscriber.getConnectionId());
  statsMessage.setLong("sessionId", subscriber.getSessionId());
  statsMessage.setString("selector", subscriber.getSelector());
  statsMessage.setLong("enqueueCounter", subscriber.getEnqueueCounter());
  statsMessage.setLong("dequeueCounter", subscriber.getDequeueCounter());
  statsMessage.setLong("dispatchedCounter", subscriber.getDispatchedCounter());
  statsMessage.setLong("dispatchedQueueSize", subscriber.getDispatchedQueueSize());
  statsMessage.setInt("prefetchSize", subscriber.getPrefetchSize());
  statsMessage.setInt("maximumPendingMessageLimit", subscriber.getMaximumPendingMessageLimit());
  statsMessage.setBoolean("exclusive", subscriber.isExclusive());
  statsMessage.setBoolean("retroactive", subscriber.isRetroactive());
  statsMessage.setBoolean("slowConsumer", subscriber.isSlowConsumer());
  return statsMessage;
}

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

public BrokerId getBrokerId() {
  return next.getBrokerId();
}

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

@Override
public void setBrokerService(BrokerService brokerService) {
  this.brokerService = brokerService;
  this.localBrokerId = brokerService.getRegionBroker().getBrokerId();
  localBrokerPath[0] = localBrokerId;
}

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

@Override
public void setBrokerService(BrokerService brokerService) {
  this.brokerService = brokerService;
  this.localBrokerId = brokerService.getRegionBroker().getBrokerId();
  localBrokerPath[0] = localBrokerId;
}

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

@Override
public void setBrokerService(BrokerService brokerService) {
  this.brokerService = brokerService;
  this.localBrokerId = brokerService.getRegionBroker().getBrokerId();
  localBrokerPath[0] = localBrokerId;
}

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

@Override
public BrokerId getBrokerId() {
  return getNext().getBrokerId();
}

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

@Override
public BrokerId getBrokerId() {
  return getNext().getBrokerId();
}

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

@Override
public BrokerId getBrokerId() {
  return getNext().getBrokerId();
}

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

public BrokerId getBrokerId() {
  return getNext().getBrokerId();
}

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

/**
 * @return the unique id of the Broker
 */
public String getBrokerId(){
  try {
    return brokerService.getBroker().getBrokerId().toString();
  } catch (Exception e) {
    return "";
  }
}

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

/**
 * @return the unique id of the Broker
 */
public String getBrokerId(){
  try {
    return brokerService.getBroker().getBrokerId().toString();
  } catch (Exception e) {
    return "";
  }
}

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

/**
 * @return the unique id of the Broker
 */
public String getBrokerId(){
  try {
    return brokerService.getBroker().getBrokerId().toString();
  } catch (Exception e) {
    return "";
  }
}

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

protected ActiveMQMapMessage prepareSubscriptionMessage(SubscriptionViewMBean subscriber) throws JMSException {
  Broker regionBroker = getBrokerService().getRegionBroker();
  ActiveMQMapMessage statsMessage = new ActiveMQMapMessage();
  statsMessage.setString("brokerName", regionBroker.getBrokerName());
  statsMessage.setString("brokerId", regionBroker.getBrokerId().toString());
  statsMessage.setString("destinationName", subscriber.getDestinationName());
  statsMessage.setString("clientId", subscriber.getClientId());
  statsMessage.setString("connectionId", subscriber.getConnectionId());
  statsMessage.setLong("sessionId", subscriber.getSessionId());
  statsMessage.setString("selector", subscriber.getSelector());
  statsMessage.setLong("enqueueCounter", subscriber.getEnqueueCounter());
  statsMessage.setLong("dequeueCounter", subscriber.getDequeueCounter());
  statsMessage.setLong("dispatchedCounter", subscriber.getDispatchedCounter());
  statsMessage.setLong("dispatchedQueueSize", subscriber.getDispatchedQueueSize());
  statsMessage.setInt("prefetchSize", subscriber.getPrefetchSize());
  statsMessage.setInt("maximumPendingMessageLimit", subscriber.getMaximumPendingMessageLimit());
  statsMessage.setBoolean("exclusive", subscriber.isExclusive());
  statsMessage.setBoolean("retroactive", subscriber.isRetroactive());
  statsMessage.setBoolean("slowConsumer", subscriber.isSlowConsumer());
  return statsMessage;
}

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

protected ActiveMQMapMessage prepareSubscriptionMessage(SubscriptionViewMBean subscriber) throws JMSException {
  Broker regionBroker = getBrokerService().getRegionBroker();
  ActiveMQMapMessage statsMessage = new ActiveMQMapMessage();
  statsMessage.setString("brokerName", regionBroker.getBrokerName());
  statsMessage.setString("brokerId", regionBroker.getBrokerId().toString());
  statsMessage.setString("destinationName", subscriber.getDestinationName());
  statsMessage.setString("clientId", subscriber.getClientId());
  statsMessage.setString("connectionId", subscriber.getConnectionId());
  statsMessage.setLong("sessionId", subscriber.getSessionId());
  statsMessage.setString("selector", subscriber.getSelector());
  statsMessage.setLong("enqueueCounter", subscriber.getEnqueueCounter());
  statsMessage.setLong("dequeueCounter", subscriber.getDequeueCounter());
  statsMessage.setLong("dispatchedCounter", subscriber.getDispatchedCounter());
  statsMessage.setLong("dispatchedQueueSize", subscriber.getDispatchedQueueSize());
  statsMessage.setInt("prefetchSize", subscriber.getPrefetchSize());
  statsMessage.setInt("maximumPendingMessageLimit", subscriber.getMaximumPendingMessageLimit());
  statsMessage.setBoolean("exclusive", subscriber.isExclusive());
  statsMessage.setBoolean("retroactive", subscriber.isRetroactive());
  statsMessage.setBoolean("slowConsumer", subscriber.isSlowConsumer());
  return statsMessage;
}

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

protected ActiveMQMapMessage prepareSubscriptionMessage(SubscriptionViewMBean subscriber) throws JMSException {
  Broker regionBroker = getBrokerService().getRegionBroker();
  ActiveMQMapMessage statsMessage = new ActiveMQMapMessage();
  statsMessage.setString("brokerName", regionBroker.getBrokerName());
  statsMessage.setString("brokerId", regionBroker.getBrokerId().toString());
  statsMessage.setString("destinationName", subscriber.getDestinationName());
  statsMessage.setString("clientId", subscriber.getClientId());
  statsMessage.setString("connectionId", subscriber.getConnectionId());
  statsMessage.setLong("sessionId", subscriber.getSessionId());
  statsMessage.setString("selector", subscriber.getSelector());
  statsMessage.setLong("enqueueCounter", subscriber.getEnqueueCounter());
  statsMessage.setLong("dequeueCounter", subscriber.getDequeueCounter());
  statsMessage.setLong("dispatchedCounter", subscriber.getDispatchedCounter());
  statsMessage.setLong("dispatchedQueueSize", subscriber.getDispatchedQueueSize());
  statsMessage.setInt("prefetchSize", subscriber.getPrefetchSize());
  statsMessage.setInt("maximumPendingMessageLimit", subscriber.getMaximumPendingMessageLimit());
  statsMessage.setBoolean("exclusive", subscriber.isExclusive());
  statsMessage.setBoolean("retroactive", subscriber.isRetroactive());
  statsMessage.setBoolean("slowConsumer", subscriber.isSlowConsumer());
  return statsMessage;
}