You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/02/16 02:37:51 UTC

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

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;