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 723911d78f..341eff660e 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
@@ -1001,6 +1001,7 @@ public class BrokerService implements Service {
             for (Iterator iter = getNetworkConnectors().iterator(); iter.hasNext();) {
                 NetworkConnector connector = (NetworkConnector) iter.next();
                 connector.setBrokerName(getBrokerName());
+                connector.setDurableDestinations(getBroker().getDurableDestinations());
                 connector.start();
             }
             
diff --git a/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java b/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
index 9a1784829a..ae659632fa 100644
--- a/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
+++ b/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
@@ -19,6 +19,7 @@ package org.apache.activemq.network;
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
+import java.util.Set;
 
 import org.apache.activemq.Service;
 import org.apache.activemq.broker.BrokerService;
@@ -47,6 +48,7 @@ public class NetworkConnector implements Service, DiscoveryListener {
     private URI localURI;
 
     private ConcurrentHashMap bridges = new ConcurrentHashMap();
+    private Set durableDestinations;
     boolean failover=true;
     
     
@@ -224,4 +226,20 @@ public class NetworkConnector implements Service, DiscoveryListener {
         this.brokerName=brokerName;
     }
 
+
+    /**
+     * @return Returns the durableDestinations.
+     */
+    public Set getDurableDestinations(){
+        return durableDestinations;
+    }
+
+
+    /**
+     * @param durableDestinations The durableDestinations to set.
+     */
+    public void setDurableDestinations(Set durableDestinations){
+        this.durableDestinations=durableDestinations;
+    }
+
 }