svn commit: r377421 - in /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq: broker/BrokerService.java network/NetworkConnector.java

[rajdavies]

Author: rajdavies
Date: Mon Feb 13 08:52:03 2006
New Revision: 377421

URL: http://svn.apache.org/viewcvs?rev=377421&view=rev
Log:
Set existing durable destinations on a network connector

Modified:
    
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
    
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.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=377421&r1=377420&r2=377421&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
 Mon Feb 13 08:52:03 2006
@@ -1001,6 +1001,7 @@
             for (Iterator iter = getNetworkConnectors().iterator(); 
iter.hasNext();) {
                 NetworkConnector connector = (NetworkConnector) iter.next();
                 connector.setBrokerName(getBrokerName());
+                
connector.setDurableDestinations(getBroker().getDurableDestinations());
                 connector.start();
             }
             

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java?rev=377421&r1=377420&r2=377421&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
 Mon Feb 13 08:52:03 2006
@@ -19,6 +19,7 @@
 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 @@
     private URI localURI;
 
     private ConcurrentHashMap bridges = new ConcurrentHashMap();
+    private Set durableDestinations;
     boolean failover=true;
     
     
@@ -222,6 +224,22 @@
      */
     public void setBrokerName(String brokerName){
         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;
     }
 
 }