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

Minor code relayout

Browse Source
This commit is contained in:
selva.andre
2013-09-19 12:22:06 +02:00
parent 8f10f3ed15
commit 576704562e
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
parser/src/main/java/org/dna/mqtt/moquette/proto/MQTTLoggingFilter.java
+11 -8
View File
@@ -109,22 +109,25 @@ public class MQTTLoggingFilter extends LoggingFilter {
}
@Override
public void messageReceived(NextFilter nextFilter, IoSession session,
Object message) throws Exception {
public void messageReceived(NextFilter nextFilter, IoSession session, Object message) throws Exception {
if (message instanceof AbstractIoBuffer) {
IoBuffer buff = (AbstractIoBuffer) message;
log(getMessageReceivedLogLevel(), "RECEIVED: {}", decodeCommonHeader(buff));
log(getMessageReceivedLogLevel(), "-> RECEIVED: {}", decodeCommonHeader(buff) + "\n\t" + buff.getHexDump());
} else {
log(getMessageReceivedLogLevel(), "RECEIVED: {}", message);
log(getMessageReceivedLogLevel(), "-> RECEIVED: {}", message);
}
nextFilter.messageReceived(session, message);
}
@Override
public void messageSent(NextFilter nextFilter, IoSession session,
WriteRequest writeRequest) throws Exception {
log(getMessageSentLogLevel(), "SENT: {}", writeRequest.getMessage());
public void messageSent(NextFilter nextFilter, IoSession session, WriteRequest writeRequest) throws Exception {
Object message = writeRequest.getMessage();
if (message instanceof AbstractIoBuffer) {
IoBuffer buff = (AbstractIoBuffer) message;
log(getMessageReceivedLogLevel(), "<- SENT: {}", buff.getHexDump());
} else {
log(getMessageReceivedLogLevel(), "<- SENT: {}", message);
}
nextFilter.messageSent(session, writeRequest);
}