You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jl...@apache.org on 2006/11/21 09:15:10 UTC
svn commit: r477570 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Author: jlim
Date: Tue Nov 21 00:15:10 2006
New Revision: 477570
URL: http://svn.apache.org/viewvc?view=rev&rev=477570
Log:
applied patch for http://issues.apache.org/activemq/browse/AMQ-1029
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/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java?view=diff&rev=477570&r1=477569&r2=477570
==============================================================================
--- 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 Tue Nov 21 00:15:10 2006
@@ -1463,9 +1463,18 @@
*/
protected void startAllConnectors() throws Exception{
if (!isSlave()){
+
+ ArrayList al = new ArrayList();
+
for (Iterator iter = getTransportConnectors().iterator(); iter.hasNext();) {
TransportConnector connector = (TransportConnector) iter.next();
- startTransportConnector(connector);
+ al.add(startTransportConnector(connector));
+ }
+
+ if (al.size()>0) {
+ //let's clear the transportConnectors list and replace it with the started transportConnector instances
+ this.transportConnectors.clear();
+ setTransportConnectors(al);
}
for (Iterator iter = getNetworkConnectors().iterator(); iter.hasNext();) {
@@ -1495,7 +1504,7 @@
}
}
- protected void startTransportConnector(TransportConnector connector) throws Exception {
+ protected TransportConnector startTransportConnector(TransportConnector connector) throws Exception {
connector.setBroker(getBroker());
connector.setBrokerName(getBrokerName());
connector.setTaskRunnerFactory(getTaskRunnerFactory());
@@ -1508,6 +1517,8 @@
connector = registerConnectorMBean(connector);
}
connector.start();
+
+ return connector;
}
/**