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

Set existing durable destinations on a network connector 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@377421 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2006-02-13 16:52:03 +00:00
parent debd0cc241
commit e7106d31b1
2 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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();
}

18
activemq-core/src/main/java/org/apache/activemq/network/NetworkConnector.java
View File

@ -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;
}
}