diff --git a/src/main/java/com/corundumstudio/socketio/SocketIOEncoder.java b/src/main/java/com/corundumstudio/socketio/SocketIOEncoder.java index d9ba8bf..fa2dc96 100644 --- a/src/main/java/com/corundumstudio/socketio/SocketIOEncoder.java +++ b/src/main/java/com/corundumstudio/socketio/SocketIOEncoder.java @@ -138,7 +138,7 @@ public class SocketIOEncoder extends ChannelOutboundHandlerAdapter implements Di if (log.isTraceEnabled()) { log.trace("Out message: {} - sessionId: {}", - new Object[] { out.toString(CharsetUtil.UTF_8), msg.getSessionId() }); + out.toString(CharsetUtil.UTF_8), msg.getSessionId()); } if (out.isReadable()) { channel.write(out); @@ -214,8 +214,8 @@ public class SocketIOEncoder extends ChannelOutboundHandlerAdapter implements Di private void handle(WebSocketPacketMessage webSocketPacketMessage, Channel channel, ByteBuf out) throws IOException { encoder.encodePacket(webSocketPacketMessage.getPacket(), out); WebSocketFrame res = new TextWebSocketFrame(out); - log.trace("Out message: {} sessionId: {}", new Object[] { - out.toString(CharsetUtil.UTF_8), webSocketPacketMessage.getSessionId()}); + log.trace("Out message: {} sessionId: {}", + out.toString(CharsetUtil.UTF_8), webSocketPacketMessage.getSessionId()); channel.writeAndFlush(res); if (!out.isReadable()) { out.release(); diff --git a/src/main/java/com/corundumstudio/socketio/handler/PacketHandler.java b/src/main/java/com/corundumstudio/socketio/handler/PacketHandler.java index 6e837a9..8b23da2 100644 --- a/src/main/java/com/corundumstudio/socketio/handler/PacketHandler.java +++ b/src/main/java/com/corundumstudio/socketio/handler/PacketHandler.java @@ -56,7 +56,7 @@ public class PacketHandler extends SimpleChannelInboundHandler { BaseClient client = message.getClient(); if (log.isTraceEnabled()) { - log.trace("In message: {} sessionId: {}", new Object[] {content.toString(CharsetUtil.UTF_8), client.getSessionId()}); + log.trace("In message: {} sessionId: {}", content.toString(CharsetUtil.UTF_8), client.getSessionId()); } while (content.isReadable()) { try { diff --git a/src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java b/src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java index d877d85..d7455b6 100644 --- a/src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java +++ b/src/main/java/com/corundumstudio/socketio/transport/WebSocketTransport.java @@ -121,7 +121,7 @@ public class WebSocketTransport extends BaseTransport { String[] parts = path.split("/"); if (parts.length <= 3) { log.warn("Wrong GET request path: {}, from ip: {}. Channel closed!", - new Object[] {path, channel.remoteAddress()}); + path, channel.remoteAddress()); channel.close(); return; } @@ -151,8 +151,8 @@ public class WebSocketTransport extends BaseTransport { private void connectClient(Channel channel, UUID sessionId) { if (!authorizeHandler.isSessionAuthorized(sessionId)) { - log.warn("Unauthorized client with sessionId: {}, from ip: {}. Channel closed!", new Object[] { - sessionId, channel.remoteAddress()}); + log.warn("Unauthorized client with sessionId: {}, from ip: {}. Channel closed!", + sessionId, channel.remoteAddress()); channel.close(); return; } diff --git a/src/main/java/com/corundumstudio/socketio/transport/XHRPollingTransport.java b/src/main/java/com/corundumstudio/socketio/transport/XHRPollingTransport.java index 815f1d0..67fa90b 100644 --- a/src/main/java/com/corundumstudio/socketio/transport/XHRPollingTransport.java +++ b/src/main/java/com/corundumstudio/socketio/transport/XHRPollingTransport.java @@ -113,7 +113,7 @@ public class XHRPollingTransport extends BaseTransport { } } else { log.warn("Wrong {} method request path: {}, from ip: {}. Channel closed!", - new Object[] {req.getMethod(), path, ctx.channel().remoteAddress()}); + req.getMethod(), path, ctx.channel().remoteAddress()); ctx.channel().close(); } }