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

Applied patch for https://issues.apache.org/activemq/browse/AMQ-1621 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@692341 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-09-05 05:57:10 +00:00
parent 78aac70bff
commit eaea51654d
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
activemq-core/src/main/java/org/apache/activemq/network/jms/JmsConnector.java
View File

@ -140,6 +140,11 @@ public abstract class JmsConnector implements Service {
LOG.info("JMS Connector " + getName() + " Stopped"); LOG.info("JMS Connector " + getName() + " Stopped");
} }
} }
public void clearBridges() {
inboundBridges.clear();
outboundBridges.clear();
}
protected abstract Destination createReplyToBridge(Destination destination, Connection consumerConnection, Connection producerConnection); protected abstract Destination createReplyToBridge(Destination destination, Connection consumerConnection, Connection producerConnection);
@ -318,11 +323,11 @@ public abstract class JmsConnector implements Service {
} }
protected void removeInboundBridge(DestinationBridge bridge) { protected void removeInboundBridge(DestinationBridge bridge) {
inboundBridges.add(bridge); inboundBridges.remove(bridge);
} }
protected void removeOutboundBridge(DestinationBridge bridge) { protected void removeOutboundBridge(DestinationBridge bridge) {
outboundBridges.add(bridge); outboundBridges.remove(bridge);
} }
public String getName() { public String getName() {