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

Fix for https://issues.apache.org/activemq/browse/AMQ-1521 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@604700 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-12-16 20:40:50 +00:00
parent 5582cc1751
commit a32832f4cb
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
View File

@ -394,7 +394,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge {
ConnectionError ce = (ConnectionError)command;
serviceRemoteException(ce.getException());
} else {
if (configuration.isDuplex() || createdByDuplex) {
if (isDuplex()) {
if (command.isMessage()) {
ActiveMQMessage message = (ActiveMQMessage)command;
if (AdvisorySupport.isConsumerAdvisoryTopic(message.getDestination())) {
@ -569,7 +569,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge {
LOG.trace("bridging " + configuration.getBrokerName() + " -> " + remoteBrokerName + ": " + message);
}
if (!message.isResponseRequired()) {
if (!message.isResponseRequired() || isDuplex()) {
// If the message was originally sent using async
// send, we will preserve that QOS
@ -933,5 +933,9 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge {
public long getEnqueueCounter() {
return enqueueCounter.get();
}
protected boolean isDuplex() {
return configuration.isDuplex() || createdByDuplex;
}
}