anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Minor change, added loggin for testing ProtocolDecodingServer

Browse Source
This commit is contained in:
andsel
2016-01-03 17:29:44 +01:00
parent 5f83465529
commit cf252da519
2 changed files with 29 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
netty_parser/src/test/java/io/moquette/parser/netty/performance/ProtocolDecodingServer.java
+2 -2
View File
@@ -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));
netty_parser/src/test/resources/log4j.properties
+27
View File
@@ -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