From 737fa4e46e32fd17c2f20ea47845066e0937d2d8 Mon Sep 17 00:00:00 2001 From: jbonofre Date: Thu, 7 Jan 2021 12:28:26 +0100 Subject: [PATCH] [AMQ-8060] Re add allowLinkStealing on transport connector for backward compatibility (cherry picked from commit 0146d5eb3e69e086ec19df1df1b2b7966c644d26) --- .../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 3de2a4ab6b..270d47d529 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 peerBrokers = new LinkedList(); @@ -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; }