From 8e24037049b54156556451d6c80746a91adee2ba Mon Sep 17 00:00:00 2001
From: Mohd Quamar Tyagi <104281681+Tyagiquamar@users.noreply.github.com>
Date: Sat, 19 Sep 2026 00:10:48 +0530
Subject: [PATCH] fix(messaging): synchronize StreamingMessageHandler NetMQ
 socket sends

---
 Messaging/StreamingMessageHandler.cs | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/Messaging/StreamingMessageHandler.cs b/Messaging/StreamingMessageHandler.cs
index 7f2c2df4ab08..9eb621a1a82c 100644
--- a/Messaging/StreamingMessageHandler.cs
+++ b/Messaging/StreamingMessageHandler.cs
@@ -37,6 +37,7 @@ public class StreamingMessageHandler : IMessagingHandler
         private PushSocket _server;
         private AlgorithmNodePacket _job;
         private OrderEventJsonConverter _orderEventJsonConverter;
+        private readonly object _socketLock = new object();
 
         /// <summary>
         /// Gets or sets whether this messaging handler has any current subscribers.
@@ -100,7 +101,10 @@ public void Transmit(Packet packet)
 
             message.Append(payload);
 
-            _server.SendMultipartMessage(message);
+            lock (_socketLock)
+            {
+                _server?.SendMultipartMessage(message);
+            }
         }
 
         /// <summary>
@@ -126,6 +130,11 @@ private void CheckPort()
         /// </summary>
         public void Dispose()
         {
+            lock (_socketLock)
+            {
+                _server?.Dispose();
+                _server = null;
+            }
         }
     }
 }