From ec15f72dcbb86ee544d16bd5b595836f83237639 Mon Sep 17 00:00:00 2001 From: Nikita Date: Wed, 31 Jul 2013 09:48:31 +0400 Subject: [PATCH] Minor changes --- .../com/corundumstudio/socketio/SocketIOEncoder.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/corundumstudio/socketio/SocketIOEncoder.java b/src/main/java/com/corundumstudio/socketio/SocketIOEncoder.java index c8af224..93168c1 100644 --- a/src/main/java/com/corundumstudio/socketio/SocketIOEncoder.java +++ b/src/main/java/com/corundumstudio/socketio/SocketIOEncoder.java @@ -67,7 +67,7 @@ public class SocketIOEncoder extends ChannelOutboundHandlerAdapter implements Di class XHRClientEntry { - // AtomicInteger works faster than locking + // works faster than locking final AtomicReference lastChannel = new AtomicReference(); final Queue packets = new ConcurrentLinkedQueue(); @@ -130,11 +130,11 @@ public class SocketIOEncoder extends ChannelOutboundHandlerAdapter implements Di HttpResponse res = createHttpResponse(origin, out); channel.write(res); + if (log.isTraceEnabled()) { + log.trace("Out message: {} - sessionId: {}", + new Object[] { out.toString(CharsetUtil.UTF_8), sessionId }); + } if (out.isReadable()) { - if (log.isTraceEnabled()) { - log.trace("Out message: {} - sessionId: {}", - new Object[] { out.toString(CharsetUtil.UTF_8), sessionId }); - } channel.write(out); } else { out.release();