Author: chirino
Date: Wed Feb 15 09:09:18 2006
New Revision: 378037

URL: http://svn.apache.org/viewcvs?rev=378037&view=rev
Log:
Fix for http://jira.activemq.org/jira/browse/AMQ-568

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=378037&r1=378036&r2=378037&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 09:09:18 2006
@@ -158,6 +158,8 @@
             connector.setDiscoveryUri(discoveryUri);
         }
         connector.setBroker(getBroker());
+        connector.setBrokerName(getBrokerName());
+        connector.setTaskRunnerFactory(getTaskRunnerFactory());
         transportConnectors.add(connector);
         if (isUseJmx()) {
             registerConnectorMBean(connector);
@@ -630,8 +632,6 @@
     public void setTransportConnectors(List transportConnectors) throws Exception {
         for (Iterator iter = transportConnectors.iterator(); iter.hasNext();) {
             TransportConnector connector = (TransportConnector) iter.next();
-            connector.setBroker(getBroker());
-            connector.setBrokerName(getBrokerName());
             addConnector(connector);
         }
     }