diff --git a/src/main/java/com/corundumstudio/socketio/handler/WrongUrlHandler.java b/src/main/java/com/corundumstudio/socketio/handler/WrongUrlHandler.java index 147e48e..0b7c888 100644 --- a/src/main/java/com/corundumstudio/socketio/handler/WrongUrlHandler.java +++ b/src/main/java/com/corundumstudio/socketio/handler/WrongUrlHandler.java @@ -50,6 +50,7 @@ public class WrongUrlHandler extends ChannelInboundHandlerAdapter { req.release(); log.warn("Blocked wrong socket.io-context request! url: {}, params: {}, ip: {}", queryDecoder.path(), queryDecoder.parameters(), channel.remoteAddress()); } + ReferenceCountUtil.release(msg); } }