diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
index ec97b79401..13870cc742 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
@@ -1818,7 +1818,7 @@ public class BrokerService implements Service {
      */
     protected void startAllConnectors() throws Exception {
         if (!isSlave()) {
-
+        	Set<ActiveMQDestination> durableDestinations = getBroker().getDurableDestinations();
             List<TransportConnector> al = new ArrayList<TransportConnector>();
 
             for (Iterator<TransportConnector> iter = getTransportConnectors().iterator(); iter.hasNext();) {
@@ -1843,7 +1843,7 @@ public class BrokerService implements Service {
                 NetworkConnector connector = iter.next();
                 connector.setLocalUri(uri);
                 connector.setBrokerName(getBrokerName());
-                connector.setDurableDestinations(getBroker().getDurableDestinations());
+                connector.setDurableDestinations(durableDestinations);
                 connector.start();
             }