Update Namespace.java

9 years ago · 1b7f44b161
1 changed files with 5 additions and 0 deletions
--- a/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java
+++ b/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java
@ -175,6 +175,11 @@ public class Namespace implements SocketIONamespace {
        leave(getName(), client.getSessionId());
        storeFactory.pubSubStore().publish(PubSubType.LEAVE, new JoinLeaveMessage(client.getSessionId(), getName(), getName()));

+        for (String joinedRoom : joinedRooms) {
+            leave(roomClients, joinedRoom, client.getSessionId());
+        }
+        clientRooms.remove(client.getSessionId());
+
        try {
            for (DisconnectListener listener : disconnectListeners) {
                listener.onDisconnect(client);