activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject git commit: Fix for https://issues.apache.org/jira/browse/AMQ-4719
Date Tue, 12 Nov 2013 08:22:47 GMT
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 <rajdavies@gmail.com>
Authored: Tue Nov 12 08:22:19 2013 +0000
Committer: Rob Davies <rajdavies@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;
+    }
 
 }


Mime
View raw message