Fix for https://issues.apache.org/jira/browse/AMQ-4719
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/11ad9482 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/11ad9482 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/11ad9482 Branch: refs/heads/activemq-5.9 Commit: 11ad9482e452ef3f62224279e927e2010a4a81b7 Parents: 5e406e6 Author: Rob Davies <[email protected]> Authored: Tue Nov 12 08:08:07 2013 +0000 Committer: Hadrian Zbarcea <[email protected]> Committed: Wed Mar 12 10:24:43 2014 -0400 ---------------------------------------------------------------------- .../org/apache/activemq/broker/TransportConnector.java | 4 ++++ .../apache/activemq/transport/vm/VMTransportServer.java | 10 ++++++++++ 2 files changed, 14 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/11ad9482/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java index 4e31ee0..582bc3f 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java @@ -90,6 +90,9 @@ public class TransportConnector implements Connector, BrokerServiceAware { setEnableStatusMonitor(false); } } + if (server != null){ + setAllowLinkStealing(server.isAllowLinkStealing()); + } } /** @@ -123,6 +126,7 @@ public class TransportConnector implements Connector, BrokerServiceAware { rc.setMaximumConsumersAllowedPerConnection(getMaximumConsumersAllowedPerConnection()); rc.setMaximumProducersAllowedPerConnection(getMaximumProducersAllowedPerConnection()); rc.setPublishedAddressPolicy(getPublishedAddressPolicy()); + rc.setAllowLinkStealing(isAllowLinkStealing()); return rc; } http://git-wip-us.apache.org/repos/asf/activemq/blob/11ad9482/activemq-broker/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java b/activemq-broker/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java index b3dd21d..2f3d519 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java +++ b/activemq-broker/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java @@ -39,6 +39,7 @@ public class VMTransportServer implements TransportServer { private final AtomicInteger connectionCount = new AtomicInteger(0); private final boolean disposeOnDisconnect; + private boolean allowLinkStealing; /** * @param location @@ -142,4 +143,13 @@ public class VMTransportServer implements TransportServer { public boolean isSslServer() { return false; } + + @Override + public boolean isAllowLinkStealing() { + return allowLinkStealing; + } + + public void setAllowLinkStealing(boolean allowLinkStealing) { + this.allowLinkStealing = allowLinkStealing; + } }
