activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r378137 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Date Thu, 16 Feb 2006 01:37:51 GMT
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;



Mime
View raw message