Remove invalid ZMQ option

ROUTING_ID is for router/dealer sockets
Abc-Arbitrage · Nov 9, 2021 · 965a68d · 965a68d
1 parent a10b99f
commit 965a68d
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 3 deletions.
diff --git a/src/Abc.Zebus/Transport/ZmqInboundSocket.cs b/src/Abc.Zebus/Transport/ZmqInboundSocket.cs
@@ -68,7 +68,6 @@ private ZmqSocket CreateSocket()
             var socket = new ZmqSocket(_context, ZmqSocketType.PULL);
             socket.SetOption(ZmqSocketOption.RCVHWM, _options.ReceiveHighWaterMark);
             socket.SetOption(ZmqSocketOption.RCVTIMEO, (int)_options.ReceiveTimeout.TotalMilliseconds);
-            socket.SetOption(ZmqSocketOption.ROUTING_ID, Encoding.ASCII.GetBytes(_peerId.ToString()));
 
             _lastReceiveTimeout = _options.ReceiveTimeout;
 

diff --git a/src/Abc.Zebus/Transport/ZmqOutboundSocket.cs b/src/Abc.Zebus/Transport/ZmqOutboundSocket.cs
@@ -77,8 +77,6 @@ private ZmqSocket CreateSocket()
                     socket.SetOption(ZmqSocketOption.TCP_KEEPALIVE_INTVL, (int)_options.KeepAlive.KeepAliveInterval.Value.TotalSeconds);
             }
 
-            socket.SetOption(ZmqSocketOption.ROUTING_ID, Encoding.ASCII.GetBytes(PeerId.ToString()));
-
             return socket;
         }
-Original file line number
+Diff line change
@@ Expand Up / @@ -77,8 +77,6 @@ private ZmqSocket CreateSocket() @@
                         socket.SetOption(ZmqSocketOption.TCP_KEEPALIVE_INTVL, (int)_options.KeepAlive.KeepAliveInterval.Value.TotalSeconds);
                 }
-                socket.SetOption(ZmqSocketOption.ROUTING_ID, Encoding.ASCII.GetBytes(PeerId.ToString()));
                 return socket;
             }
@@ Expand Down @@