fix subscription overriding (#329)

microsoft · Apr 26, 2024 · 4dc3b75 · 4dc3b75
1 parent 02649c9
commit 4dc3b75
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/libs/server/PubSub/SubscribeBroker.cs b/libs/server/PubSub/SubscribeBroker.cs
@@ -226,7 +226,7 @@ public unsafe int Subscribe(ref byte* key, ServerSessionBase session)
             var subscriptionKey = new Span<byte>(start, (int)(key - start)).ToArray();
             subscriptions.TryAdd(subscriptionKey, new ConcurrentDictionary<int, ServerSessionBase>());
             if (subscriptions.TryGetValue(subscriptionKey, out var val))
-                val.TryAdd(sid, session);
+                val.TryAdd(id, session);
             return id;
         }
 
@@ -256,7 +256,7 @@ public unsafe int PSubscribe(ref byte* prefix, ServerSessionBase session, bool a
             var subscriptionPrefix = new Span<byte>(start, (int)(prefix - start)).ToArray();
             prefixSubscriptions.TryAdd(subscriptionPrefix, (ascii, new ConcurrentDictionary<int, ServerSessionBase>()));
             if (prefixSubscriptions.TryGetValue(subscriptionPrefix, out var val))
-                val.Item2.TryAdd(sid, session);
+                val.Item2.TryAdd(id, session);
             return id;
         }