Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix for http://issues.apache.org/activemq/browse/AMQ-1709 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@656601 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-05-15 11:58:12 +00:00
parent a4b7157513
commit 2aa661d724
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
View File

@ -1818,7 +1818,7 @@ public class BrokerService implements Service {
*/ */
protected void startAllConnectors() throws Exception { protected void startAllConnectors() throws Exception {
if (!isSlave()) { if (!isSlave()) {
Set<ActiveMQDestination> durableDestinations = getBroker().getDurableDestinations();
List<TransportConnector> al = new ArrayList<TransportConnector>(); List<TransportConnector> al = new ArrayList<TransportConnector>();
for (Iterator<TransportConnector> iter = getTransportConnectors().iterator(); iter.hasNext();) { for (Iterator<TransportConnector> iter = getTransportConnectors().iterator(); iter.hasNext();) {
@ -1843,7 +1843,7 @@ public class BrokerService implements Service {
NetworkConnector connector = iter.next(); NetworkConnector connector = iter.next();
connector.setLocalUri(uri); connector.setLocalUri(uri);
connector.setBrokerName(getBrokerName()); connector.setBrokerName(getBrokerName());
connector.setDurableDestinations(getBroker().getDurableDestinations()); connector.setDurableDestinations(durableDestinations);
connector.start(); connector.start();
} }