Fix issue #437 use extend logger class name for messageLogger
This commit is contained in:
@@ -179,8 +179,7 @@ public class Server {
|
||||
ISubscriptionsDirectory subscriptions = new CTrieSubscriptionDirectory();
|
||||
subscriptions.init(subscriptionsRepository);
|
||||
SessionRegistry sessions = new SessionRegistry(subscriptions, queueRepository);
|
||||
dispatcher = new PostOffice(subscriptions, authorizatorPolicy, retainedRepository, sessions,
|
||||
interceptor);
|
||||
dispatcher = new PostOffice(subscriptions, authorizatorPolicy, retainedRepository, sessions, interceptor);
|
||||
final BrokerConfiguration brokerConfig = new BrokerConfiguration(config);
|
||||
MQTTConnectionFactory connectionFactory = new MQTTConnectionFactory(brokerConfig, authenticator, sessions,
|
||||
dispatcher);
|
||||
|
||||
@@ -38,7 +38,7 @@ import static io.netty.channel.ChannelFutureListener.CLOSE_ON_FAILURE;
|
||||
@Sharable
|
||||
public class MQTTMessageLogger extends ChannelDuplexHandler {
|
||||
|
||||
private static final Logger LOG = LoggerFactory.getLogger("messageLogger");
|
||||
private static final Logger LOG = LoggerFactory.getLogger(MQTTMessageLogger.class);
|
||||
|
||||
@Override
|
||||
public void channelRead(ChannelHandlerContext ctx, Object message) throws Exception {
|
||||
|
||||
@@ -40,4 +40,4 @@ log4j.appender.messagelog.MaxBackupIndex=1
|
||||
log4j.appender.messagelog.layout=org.apache.log4j.PatternLayout
|
||||
log4j.appender.messagelog.layout.ConversionPattern=%d{HH:mm:ss,SSS} [%t] %-5p %c{1} %L %x - %m%n
|
||||
|
||||
log4j.category.messageLogger=WARN, messagelog
|
||||
log4j.category.io.moquette.broker.metrics.MQTTMessageLogger=WARN, messagelog
|
||||
|
||||
@@ -44,4 +44,4 @@ log4j.appender.messagelog.MaxBackupIndex=1
|
||||
log4j.appender.messagelog.layout=org.apache.log4j.PatternLayout
|
||||
log4j.appender.messagelog.layout.ConversionPattern=%d{dd/MM/yyyy HH:mm:ss,SSS} [%t] %-5p %c{1} %L %x - %m%n
|
||||
|
||||
log4j.category.messageLogger=WARN, messagelog
|
||||
log4j.category.io.moquette.broker.metrics.MQTTMessageLogger=WARN, messagelog
|
||||
|
||||
Reference in New Issue
Block a user