svn commit: r391821 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java

[chirino]

Author: chirino
Date: Wed Apr  5 14:26:03 2006
New Revision: 391821

URL: http://svn.apache.org/viewcvs?rev=391821&view=rev
Log:
List the unique id of the broker when it's started and stopped.

Modified:
    
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java?rev=391821&r1=391820&r2=391821&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
 Wed Apr  5 14:26:03 2006
@@ -46,6 +46,7 @@
 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 @@
 
     private boolean keepDurableSubsActive;
 
+    private BrokerId brokerId;
+
     /**
      * Adds a new transport connector for the given bind address
      *
@@ -364,8 +367,8 @@
             
             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 @@
         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 @@
             stopper.stop(getManagementContext());
         }
 
-        log.info("ActiveMQ JMS Message Broker (" + getBrokerName() + ") 
stopped: "+broker);
+        log.info("ActiveMQ JMS Message Broker (" + getBrokerName()+", 
"+brokerId+") stopped");
 
         stopper.throwFirstException();
     }