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

https://issues.apache.org/jira/browse/AMQ-4719 - allowLinkStealing was not set/used properly by default on mqtt connector

This commit is contained in:
Dejan Bosanac 2014-08-05 16:23:45 +02:00
parent 6dd47bb63f
commit c99e2d8372
2 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -90,9 +90,6 @@ public class TransportConnector implements Connector, BrokerServiceAware {
setEnableStatusMonitor(false); setEnableStatusMonitor(false);
} }
} }
if (server != null){
setAllowLinkStealing(server.isAllowLinkStealing());
}
} }
/** /**
@ -582,7 +579,7 @@ public class TransportConnector implements Connector, BrokerServiceAware {
@Override @Override
public boolean isAllowLinkStealing() { public boolean isAllowLinkStealing() {
return allowLinkStealing; return server.isAllowLinkStealing();
} }
public void setAllowLinkStealing (boolean allowLinkStealing) { public void setAllowLinkStealing (boolean allowLinkStealing) {

8
activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTestSupport.java
View File

@ -19,6 +19,7 @@ package org.apache.activemq.transport.mqtt;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.net.URI;
import java.security.ProtectionDomain; import java.security.ProtectionDomain;
import java.security.SecureRandom; import java.security.SecureRandom;
import java.security.cert.CertificateException; import java.security.cert.CertificateException;
@ -157,6 +158,7 @@ public class MQTTTestSupport {
brokerService.start(); brokerService.start();
brokerService.waitUntilStarted(); brokerService.waitUntilStarted();
port = brokerService.getTransportConnectorByName("mqtt").getConnectUri().getPort();
} }
protected void applyMemoryLimitPolicy() throws Exception { protected void applyMemoryLimitPolicy() throws Exception {
@ -214,7 +216,11 @@ public class MQTTTestSupport {
connectorURI.append("?").append(protocolConfig); connectorURI.append("?").append(protocolConfig);
} }
port = brokerService.addConnector(connectorURI.toString()).getConnectUri().getPort(); TransportConnector connector = new TransportConnector();
connector.setUri(new URI(connectorURI.toString()));
connector.setName("mqtt");
brokerService.addConnector(connector);
LOG.info("Added connector {} to broker", getProtocolScheme()); LOG.info("Added connector {} to broker", getProtocolScheme());
} }