diff --git a/src/main/java/com/corundumstudio/socketio/handler/InPacketHandler.java b/src/main/java/com/corundumstudio/socketio/handler/InPacketHandler.java index 5e8503154..12ddc1264 100644 --- a/src/main/java/com/corundumstudio/socketio/handler/InPacketHandler.java +++ b/src/main/java/com/corundumstudio/socketio/handler/InPacketHandler.java @@ -65,7 +65,11 @@ protected void channelRead0(io.netty.channel.ChannelHandlerContext ctx, PacketsM try { Packet packet = decoder.decodePackets(content, client); - Namespace ns = namespacesHub.get(packet.getNsp()); + String namespace = packet.getNsp(); + Namespace ns = namespacesHub.get(namespace); + if (ns == null && namespace.charAt(0) == '/') + ns = namespacesHub.get(namespace.substring(1)); + if (ns == null) { if (packet.getSubType() == PacketType.CONNECT) { Packet p = new Packet(PacketType.MESSAGE, client.getEngineIOVersion());