diff --git a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java index 6727461423..dec788bd41 100755 --- a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java +++ b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridge.java @@ -747,6 +747,7 @@ public class DemandForwardingBridge implements Bridge{ if (log.isTraceEnabled()){ log.trace("Message all ready routed once through this broker - ignoring: " + message); } + return false; } int hops = message.getBrokerPath() == null ? 0 : message.getBrokerPath().length; if(hops >= networkTTL){