Browse Source

Remove unused parameter

Lucas Trzesniewski 1 year ago
parent
commit
83b5257769

+ 1 - 3
src/Abc.Zebus/Transport/ZmqInboundSocket.cs

@@ -15,17 +15,15 @@ namespace Abc.Zebus.Transport
         private static readonly Regex _ipRegex = new(@"^(?:[0-9]+\.){3}[0-9]+$");
 
         private readonly ZmqContext _context;
-        private readonly PeerId _peerId;
         private readonly ZmqEndPoint _configuredEndPoint;
         private readonly ZmqSocketOptions _options;
         private byte[] _readBuffer = Array.Empty<byte>();
         private ZmqSocket? _socket;
         private TimeSpan _lastReceiveTimeout;
 
-        public ZmqInboundSocket(ZmqContext context, PeerId peerId, ZmqEndPoint configuredEndPoint, ZmqSocketOptions options)
+        public ZmqInboundSocket(ZmqContext context, ZmqEndPoint configuredEndPoint, ZmqSocketOptions options)
         {
             _context = context;
-            _peerId = peerId;
             _configuredEndPoint = configuredEndPoint;
             _options = options;
         }

+ 1 - 1
src/Abc.Zebus/Transport/ZmqTransport.cs

@@ -216,7 +216,7 @@ namespace Abc.Zebus.Transport
             ZmqInboundSocket? inboundSocket = null;
             try
             {
-                inboundSocket = new ZmqInboundSocket(_context!, PeerId, _configuredInboundEndPoint, _socketOptions);
+                inboundSocket = new ZmqInboundSocket(_context!, _configuredInboundEndPoint, _socketOptions);
                 _effectiveInboundEndPoint = inboundSocket.Bind();
                 return inboundSocket;
             }