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/ae354f9b Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/ae354f9b Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/ae354f9b Branch: refs/heads/activemq-5.9 Commit: ae354f9b11a6dc7ee5bc8c382af26f7fa4a73448 Parents: a482a68 Author: Rob Davies <[email protected]> Authored: Tue Nov 12 08:22:19 2013 +0000 Committer: Hadrian Zbarcea <[email protected]> Committed: Wed Mar 12 10:25:24 2014 -0400 ---------------------------------------------------------------------- .../apache/activemq/transport/TransportServerSupport.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/ae354f9b/activemq-client/src/main/java/org/apache/activemq/transport/TransportServerSupport.java ---------------------------------------------------------------------- diff --git a/activemq-client/src/main/java/org/apache/activemq/transport/TransportServerSupport.java b/activemq-client/src/main/java/org/apache/activemq/transport/TransportServerSupport.java index fba8063..a6635b9 100644 --- a/activemq-client/src/main/java/org/apache/activemq/transport/TransportServerSupport.java +++ b/activemq-client/src/main/java/org/apache/activemq/transport/TransportServerSupport.java @@ -32,6 +32,7 @@ public abstract class TransportServerSupport extends ServiceSupport implements T private URI bindLocation; private TransportAcceptListener acceptListener; protected Map<String, Object> transportOptions; + protected boolean allowLinkStealing; public TransportServerSupport() { } @@ -89,5 +90,13 @@ public abstract class TransportServerSupport extends ServiceSupport implements T this.transportOptions = transportOptions; } + @Override + public boolean isAllowLinkStealing() { + return allowLinkStealing; + } + + public void setAllowLinkStealing(boolean allowLinkStealing) { + this.allowLinkStealing = allowLinkStealing; + } }
