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();