From cf252da519dcfeb96be8215ac07929eb56fa0cb1 Mon Sep 17 00:00:00 2001 From: andsel Date: Sun, 3 Jan 2016 17:29:44 +0100 Subject: [PATCH] Minor change, added loggin for testing ProtocolDecodingServer --- .../performance/ProtocolDecodingServer.java | 4 +-- .../src/test/resources/log4j.properties | 27 +++++++++++++++++++ 2 files changed, 29 insertions(+), 2 deletions(-) create mode 100644 netty_parser/src/test/resources/log4j.properties diff --git a/netty_parser/src/test/java/io/moquette/parser/netty/performance/ProtocolDecodingServer.java b/netty_parser/src/test/java/io/moquette/parser/netty/performance/ProtocolDecodingServer.java index c2f6fedb..27e4a7df 100644 --- a/netty_parser/src/test/java/io/moquette/parser/netty/performance/ProtocolDecodingServer.java +++ b/netty_parser/src/test/java/io/moquette/parser/netty/performance/ProtocolDecodingServer.java @@ -21,7 +21,7 @@ import org.slf4j.LoggerFactory; */ public class ProtocolDecodingServer { - class MoquetteIdleTimoutHandler extends ChannelDuplexHandler { + class MoquetteIdleTimeoutHandler extends ChannelDuplexHandler { @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { if (evt instanceof IdleStateEvent) { @@ -85,7 +85,7 @@ public class ProtocolDecodingServer { ChannelPipeline pipeline = ch.pipeline(); try { pipeline.addFirst("idleStateHandler", new IdleStateHandler(0, 0, Constants.DEFAULT_CONNECT_TIMEOUT)); - pipeline.addAfter("idleStateHandler", "idleEventHandler", new MoquetteIdleTimoutHandler()); + pipeline.addAfter("idleStateHandler", "idleEventHandler", new MoquetteIdleTimeoutHandler()); pipeline.addLast("decoder", new MQTTDecoder()); pipeline.addLast("encoder", new MQTTEncoder()); pipeline.addLast("handler", new LoopMQTTHandler(state)); diff --git a/netty_parser/src/test/resources/log4j.properties b/netty_parser/src/test/resources/log4j.properties new file mode 100644 index 00000000..392d00a0 --- /dev/null +++ b/netty_parser/src/test/resources/log4j.properties @@ -0,0 +1,27 @@ +# Set root logger level to DEBUG and its only appender to A1. +#log4j.rootLogger=INFO, stdout, file +log4j.rootLogger=INFO, stdout + +log4j.logger.io.moquette=WARN +log4j.logger.io.netty.util=WRN +log4j.logger.io.moquette.parser.netty.performance=WARN + +# stdout appender is set to be a ConsoleAppender. +log4j.appender.stdout=org.apache.log4j.ConsoleAppender +log4j.appender.stdout.Threshold=WARN + + +log4j.appender.stdout.layout=org.apache.log4j.PatternLayout +log4j.appender.stdout.layout.ConversionPattern=%d{HH:mm:ss,SSS} [%t] %-5p %c{1} %M %L %x - %m%n + +#file appender +#log4j.appender.file=org.apache.log4j.RollingFileAppender +#log4j.appender.file.Threshold=INFO +#log4j.appender.file.File=moquette.log +#log4j.appender.file.MaxFileSize=100MB +#log4j.appender.file.MaxBackupIndex=1 +#log4j.appender.file.layout=org.apache.log4j.PatternLayout +#log4j.appender.file.layout.ConversionPattern=%d{HH:mm:ss,SSS} [%t] %-5p %c{1} %L %x - %m%n + + +