mirror of https://github.com/apache/activemq.git
[AMQ-8060] Re add allowLinkStealing on transport connector for backward compatibility
This commit is contained in:
parent
3897d78776
commit
0146d5eb3e
|
@ -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;
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue