From 23d80b3c71065571c5c6ca458626fd681326dc2c Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Wed, 5 Apr 2006 21:26:03 +0000 Subject: [PATCH] List the unique id of the broker when it's started and stopped. git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391821 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/broker/BrokerService.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java index 746e2e1ceb..5f7dc878d5 100644 --- a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java @@ -46,6 +46,7 @@ import org.apache.activemq.broker.jmx.NetworkConnectorViewMBean; import org.apache.activemq.broker.jmx.ProxyConnectorView; import org.apache.activemq.broker.region.RegionBroker; import org.apache.activemq.broker.region.policy.PolicyMap; +import org.apache.activemq.command.BrokerId; import org.apache.activemq.memory.UsageManager; import org.apache.activemq.network.ConnectionFilter; import org.apache.activemq.network.DiscoveryNetworkConnector; @@ -119,6 +120,8 @@ public class BrokerService implements Service { private boolean keepDurableSubsActive; + private BrokerId brokerId; + /** * Adds a new transport connector for the given bind address * @@ -364,8 +367,8 @@ public class BrokerService implements Service { startAllConnectors(); - - log.info("ActiveMQ JMS Message Broker (" + getBrokerName() + ") started"); + brokerId = broker.getBrokerId(); + log.info("ActiveMQ JMS Message Broker (" + getBrokerName()+", "+brokerId+") started"); } catch (Exception e) { log.error("Failed to start ActiveMQ JMS Message Broker. Reason: " + e, e); @@ -377,7 +380,7 @@ public class BrokerService implements Service { if (! started.compareAndSet(true, false)) { return; } - log.info("ActiveMQ Message Broker (" + getBrokerName() + ") is shutting down"); + log.info("ActiveMQ Message Broker (" + getBrokerName()+", "+brokerId+") is shutting down"); BrokerRegistry.getInstance().unbind(getBrokerName()); removeShutdownHook(); @@ -433,7 +436,7 @@ public class BrokerService implements Service { stopper.stop(getManagementContext()); } - log.info("ActiveMQ JMS Message Broker (" + getBrokerName() + ") stopped: "+broker); + log.info("ActiveMQ JMS Message Broker (" + getBrokerName()+", "+brokerId+") stopped"); stopper.throwFirstException(); }