diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java index fb7083eaa8..b6404d5a84 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java +++ b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java @@ -895,7 +895,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br protected void addSubscription(DemandSubscription sub) throws IOException { if (sub != null) { - localBroker.request(sub.getLocalInfo()); + localBroker.oneway(sub.getLocalInfo()); } }