activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbono...@apache.org
Subject [activemq] branch activemq-5.16.x updated: [AMQ-8060] Re add allowLinkStealing on transport connector for backward compatibility
Date Sat, 09 Jan 2021 06:27:32 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/activemq-5.16.x by this push:
     new 737fa4e  [AMQ-8060] Re add allowLinkStealing on transport connector for backward
compatibility
737fa4e is described below

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

    [AMQ-8060] Re add allowLinkStealing on transport connector for backward compatibility
    
    (cherry picked from commit 0146d5eb3e69e086ec19df1df1b2b7966c644d26)
---
 .../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;
     }


Mime
View raw message