mirror of https://github.com/apache/activemq.git
Add more logging to aid in failing test diagnosis.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483838 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
620523a597
commit
d2d41805c5
|
@ -332,7 +332,7 @@ public abstract class AbstractMQTTTest extends AutoFailTestSupport {
|
|||
}
|
||||
|
||||
protected void addMQTTConnector(String config) throws Exception {
|
||||
mqttConnector= brokerService.addConnector(getProtocolScheme()+"://localhost:0" + config);
|
||||
mqttConnector = brokerService.addConnector(getProtocolScheme()+"://localhost:0?trace=true&" + config);
|
||||
}
|
||||
|
||||
protected void initializeConnection(MQTTClientProvider provider) throws Exception {
|
||||
|
|
|
@ -32,7 +32,7 @@ public class MQTTNioTest extends MQTTTest {
|
|||
|
||||
@Test
|
||||
public void testPingOnMQTTNIO() throws Exception {
|
||||
addMQTTConnector("?maxInactivityDuration=-1");
|
||||
addMQTTConnector("maxInactivityDuration=-1");
|
||||
brokerService.start();
|
||||
MQTT mqtt = createMQTTConnection();
|
||||
mqtt.setKeepAlive((short)2);
|
||||
|
|
|
@ -51,7 +51,7 @@ public class MQTTTest extends AbstractMQTTTest {
|
|||
|
||||
@Test(timeout=300000)
|
||||
public void testTurnOffInactivityMonitor()throws Exception{
|
||||
addMQTTConnector("?transport.useInactivityMonitor=false");
|
||||
addMQTTConnector("transport.useInactivityMonitor=false");
|
||||
brokerService.start();
|
||||
MQTT mqtt = createMQTTConnection();
|
||||
mqtt.setKeepAlive((short)2);
|
||||
|
@ -72,7 +72,7 @@ public class MQTTTest extends AbstractMQTTTest {
|
|||
@Test(timeout=30000)
|
||||
public void testDefaultKeepAliveWhenClientSpecifiesZero() throws Exception {
|
||||
// default keep alive in milliseconds
|
||||
addMQTTConnector("?transport.defaultKeepAlive=2000");
|
||||
addMQTTConnector("transport.defaultKeepAlive=2000");
|
||||
brokerService.start();
|
||||
MQTT mqtt = createMQTTConnection();
|
||||
mqtt.setKeepAlive((short)0);
|
||||
|
@ -120,11 +120,6 @@ public class MQTTTest extends AbstractMQTTTest {
|
|||
addMQTTConnector("");
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void addMQTTConnector(String config) throws Exception {
|
||||
mqttConnector = brokerService.addConnector(getProtocolScheme()+"://localhost:0" + config);
|
||||
}
|
||||
|
||||
@Override
|
||||
protected MQTTClientProvider getMQTTClientProvider() {
|
||||
return new FuseMQQTTClientProvider();
|
||||
|
@ -145,12 +140,12 @@ public class MQTTTest extends AbstractMQTTTest {
|
|||
return new Tracer(){
|
||||
@Override
|
||||
public void onReceive(MQTTFrame frame) {
|
||||
LOG.info("recv: "+frame);
|
||||
LOG.info("Client Received:\n"+frame);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onSend(MQTTFrame frame) {
|
||||
LOG.info("send: " + frame);
|
||||
LOG.info("Client Sent:\n" + frame);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
|
@ -20,18 +20,12 @@
|
|||
#
|
||||
log4j.rootLogger=INFO, out, stdout
|
||||
|
||||
#log4j.logger.org.apache.activemq.network.DemandForwardingBridgeSupport=DEBUG
|
||||
#log4j.logger.org.apache.activemq.transport.failover=TRACE
|
||||
log4j.logger.org.apache.activemq.transport.mqtt=DEBUG
|
||||
#log4j.logger.org.apache.activemq.store.jdbc=TRACE
|
||||
#log4j.logger.org.apache.activemq.broker.region.cursors.AbstractStoreCursor=DEBUG
|
||||
#log4j.logger.org.apache.activemq.store.jdbc.JDBCMessageStore=DEBUG
|
||||
log4j.logger.org.apache.activemq.transport.mqtt=TRACE
|
||||
|
||||
# CONSOLE appender not used by default
|
||||
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
|
||||
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
|
||||
log4j.appender.stdout.layout.ConversionPattern=%d [%-15.15t] - %-5p %-30.30c{1} - %m%n
|
||||
#log4j.appender.stdout.layout.ConversionPattern=%d [%-15.15t] - %-5p %-30.30c{1} - %-10.10X{activemq.broker} %-20.20X{activemq.connector} %-10.10X{activemq.destination} - %m%n
|
||||
log4j.appender.stdout.layout.ConversionPattern=%d | %-5p | %-30.30c{1} | %m%n
|
||||
|
||||
# File appender
|
||||
log4j.appender.out=org.apache.log4j.FileAppender
|
||||
|
|
Loading…
Reference in New Issue