From 1b7f44b16190ec56739a374d0aa65f8dbb7a17b9 Mon Sep 17 00:00:00 2001
From: CrazyIvan007 <CrazyIvan007@users.noreply.github.com>
Date: Fri, 1 Jul 2016 15:34:52 +0200
Subject: [PATCH] Update Namespace.java

---
 .../com/corundumstudio/socketio/namespace/Namespace.java     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java b/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java
index 2555869..35b6abe 100644
--- 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);