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

[ch...@apache.org]

Author: chirino
Date: Wed Feb  8 12:17:12 2006
New Revision: 376042

URL: http://svn.apache.org/viewcvs?rev=376042&view=rev
Log:
A little better logging to see when brokers are 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=376042&r1=376041&r2=376042&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 Feb  8 12:17:12 2006
@@ -319,8 +319,8 @@
             // as its way too easy to not be completely sure if start() has been 
             // called or not with the gazillion of different configuration mechanisms
             
-            //throw new IllegalStateException("Allready started.");
-            return;
+            throw new IllegalStateException("Allready started.");
+            //return;
         }
         
         processHelperProperties();
@@ -408,7 +408,7 @@
             stopper.stop(getManagementContext());
         }
 
-        log.info("ActiveMQ JMS Message Broker (" + getBrokerName() + ") stopped");
+        log.info("ActiveMQ JMS Message Broker (" + getBrokerName() + ") stopped: "+broker);
 
         stopper.throwFirstException();
     }
@@ -818,7 +818,7 @@
         broker = new MutableBrokerFilter(broker) {
             public void stop() throws Exception {
                 super.stop();
-                setNext(new ErrorBroker("Broker has been stopped.") {
+                setNext(new ErrorBroker("Broker has been stopped: "+this) {
                     // Just ignore additional stop actions.
                     public void stop() throws Exception {
                     }