Allow setting TimeSpan.Zero as a heartbeat timeout value

rabbitmq · Jan 24, 2025 · 276c9a6 · 276c9a6
1 parent 9c6fda8
commit 276c9a6
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/projects/RabbitMQ.Client/Impl/SocketFrameHandler.cs b/projects/RabbitMQ.Client/Impl/SocketFrameHandler.cs
@@ -111,8 +111,11 @@ public TimeSpan ReadTimeout
             {
                 try
                 {
-                    _socket.ReceiveTimeout = value;
-                    _stream.ReadTimeout = (int)value.TotalMilliseconds;
+                    if (value != default)
+                    {
+                        _socket.ReceiveTimeout = value;
+                        _stream.ReadTimeout = (int)value.TotalMilliseconds;
+                    }
                 }
                 catch (SocketException)
                 {
@@ -125,8 +128,11 @@ public TimeSpan WriteTimeout
         {
             set
             {
-                _socket.Client.SendTimeout = (int)value.TotalMilliseconds;
-                _stream.WriteTimeout = (int)value.TotalMilliseconds;
+                if (value != default)
+                {
+                    _socket.Client.SendTimeout = (int)value.TotalMilliseconds;
+                    _stream.WriteTimeout = (int)value.TotalMilliseconds;
+                }
             }
         }