From 4dc3b75700dc1a4f9898fc75ca8e0f781d7040b5 Mon Sep 17 00:00:00 2001
From: Vaibhav Bandikatla <vaibhavb995@gmail.com>
Date: Thu, 25 Apr 2024 17:33:45 -0700
Subject: [PATCH] fix subscription overriding (#329)

---
 libs/server/PubSub/SubscribeBroker.cs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/libs/server/PubSub/SubscribeBroker.cs b/libs/server/PubSub/SubscribeBroker.cs
index 73b8b560d3..d75c46a332 100644
--- 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;
         }