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

[chirino]

Author: chirino
Date: Wed Feb 15 17:37:49 2006
New Revision: 378137

URL: http://svn.apache.org/viewcvs?rev=378137&view=rev
Log:
Fixed test cases that I broke with my previous commit to this file.

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=378137&r1=378136&r2=378137&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 15 17:37:49 2006
@@ -151,17 +151,14 @@
      * @throws Exception
      */
     public TransportConnector addConnector(TransportConnector connector) 
throws Exception {
-        int what = System.identityHashCode(connector);
-        if (isUseJmx()) {
-            URI discoveryUri = connector.getDiscoveryUri();
-            connector = 
connector.asManagedConnector(getManagementContext().getMBeanServer(), 
getBrokerObjectName());
-            connector.setDiscoveryUri(discoveryUri);
-        }
+        
         connector.setBroker(getBroker());
         connector.setBrokerName(getBrokerName());
         connector.setTaskRunnerFactory(getTaskRunnerFactory());
         transportConnectors.add(connector);
+
         if (isUseJmx()) {
+            connector = 
connector.asManagedConnector(getManagementContext().getMBeanServer(), 
getBrokerObjectName());
             registerConnectorMBean(connector);
         }
         return connector;