[activemq] branch master updated: [AMQ-8060] Re add allowLinkStealing on transport connector for backward compatibility

[jbonofre]

This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/master by this push:
     new 0146d5e  [AMQ-8060] Re add allowLinkStealing on transport connector 
for backward compatibility
     new 05051e2  Merge pull request #603 from jbonofre/AMQ-8060
0146d5e is described below

commit 0146d5eb3e69e086ec19df1df1b2b7966c644d26
Author: jbonofre <jbono...@apache.org>
AuthorDate: Thu Jan 7 12:28:26 2021 +0100

    [AMQ-8060] Re add allowLinkStealing on transport connector for backward 
compatibility
---
 .../main/java/org/apache/activemq/broker/TransportConnector.java    | 6 ++++++
 1 file changed, 6 insertions(+)

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 3de2a4a..270d47d 100644
--- 
a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
+++ 
b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
@@ -76,6 +76,7 @@ public class TransportConnector implements Connector, 
BrokerServiceAware {
     private int maximumProducersAllowedPerConnection = Integer.MAX_VALUE;
     private int maximumConsumersAllowedPerConnection  = Integer.MAX_VALUE;
     private PublishedAddressPolicy publishedAddressPolicy = new 
PublishedAddressPolicy();
+    private boolean allowLinkStealing = false;
     private boolean warnOnRemoteClose = false;
 
     LinkedList<String> peerBrokers = new LinkedList<String>();
@@ -125,6 +126,7 @@ public class TransportConnector implements Connector, 
BrokerServiceAware {
         
rc.setMaximumConsumersAllowedPerConnection(getMaximumConsumersAllowedPerConnection());
         
rc.setMaximumProducersAllowedPerConnection(getMaximumProducersAllowedPerConnection());
         rc.setPublishedAddressPolicy(getPublishedAddressPolicy());
+        rc.setAllowLinkStealing(allowLinkStealing);
         rc.setWarnOnRemoteClose(isWarnOnRemoteClose());
         return rc;
     }
@@ -602,6 +604,10 @@ public class TransportConnector implements Connector, 
BrokerServiceAware {
         return server.isAllowLinkStealing();
     }
 
+    public void setAllowLinkStealing(boolean allowLinkStealing) {
+        this.allowLinkStealing = allowLinkStealing;
+    }
+
     public boolean isAuditNetworkProducers() {
         return auditNetworkProducers;
     }