Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix for https://issues.apache.org/jira/browse/AMQ-4719

This commit is contained in:
Rob Davies 2013-11-12 08:08:07 +00:00
parent 7e000d5a40
commit 47d1985139
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
View File

@ -90,6 +90,9 @@ public class TransportConnector implements Connector, BrokerServiceAware {
setEnableStatusMonitor(false); setEnableStatusMonitor(false);
} }
} }
if (server != null){
setAllowLinkStealing(server.isAllowLinkStealing());
}
} }
/** /**
@ -123,6 +126,7 @@ public class TransportConnector implements Connector, BrokerServiceAware {
rc.setMaximumConsumersAllowedPerConnection(getMaximumConsumersAllowedPerConnection()); rc.setMaximumConsumersAllowedPerConnection(getMaximumConsumersAllowedPerConnection());
rc.setMaximumProducersAllowedPerConnection(getMaximumProducersAllowedPerConnection()); rc.setMaximumProducersAllowedPerConnection(getMaximumProducersAllowedPerConnection());
rc.setPublishedAddressPolicy(getPublishedAddressPolicy()); rc.setPublishedAddressPolicy(getPublishedAddressPolicy());
rc.setAllowLinkStealing(isAllowLinkStealing());
return rc; return rc;
} }

10
activemq-broker/src/main/java/org/apache/activemq/transport/vm/VMTransportServer.java
View File

@ -39,6 +39,7 @@ public class VMTransportServer implements TransportServer {
private final AtomicInteger connectionCount = new AtomicInteger(0); private final AtomicInteger connectionCount = new AtomicInteger(0);
private final boolean disposeOnDisconnect; private final boolean disposeOnDisconnect;
private boolean allowLinkStealing;
/** /**
* @param location * @param location
@ -142,4 +143,13 @@ public class VMTransportServer implements TransportServer {
public boolean isSslServer() { public boolean isSslServer() {
return false; return false;
} }
@Override
public boolean isAllowLinkStealing() {
return allowLinkStealing;
}
public void setAllowLinkStealing(boolean allowLinkStealing) {
this.allowLinkStealing = allowLinkStealing;
}
} }