activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r391821 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Date Wed, 05 Apr 2006 21:26:05 GMT
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();
     }



Mime
View raw message