Merge pull request #1013 from bigtian99/dev

fix(namespace): prevents the client from repeatedly connecting to the namespace
mrniko · Oct 31, 2024 · 0e26a4d · 0e26a4d
2 parents 0238b47 + 969d444
commit 0e26a4d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java b/src/main/java/com/corundumstudio/socketio/namespace/Namespace.java
@@ -200,6 +200,11 @@ public void addConnectListener(ConnectListener listener) {
     }
 
     public void onConnect(SocketIOClient client) {
+        if (roomClients.containsKey(getName()) &&
+                roomClients.get(getName()).contains(client.getSessionId())) {
+            return;
+        }
+
         join(getName(), client.getSessionId());
         storeFactory.pubSubStore().publish(PubSubType.JOIN, new JoinLeaveMessage(client.getSessionId(), getName(), getName()));