You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2013/11/12 09:22:47 UTC
git commit: Fix for https://issues.apache.org/jira/browse/AMQ-4719
Updated Branches:
refs/heads/trunk d2ddd1dca -> 4183e6e47
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/4183e6e4
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/4183e6e4
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/4183e6e4
Branch: refs/heads/trunk
Commit: 4183e6e47c29f6d34313a83cb748b4c137b8a353
Parents: d2ddd1d
Author: Rob Davies <ra...@gmail.com>
Authored: Tue Nov 12 08:22:19 2013 +0000
Committer: Rob Davies <ra...@gmail.com>
Committed: Tue Nov 12 08:22:19 2013 +0000
----------------------------------------------------------------------
.../apache/activemq/transport/TransportServerSupport.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/4183e6e4/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;
+ }
}