From 276c9a6f7f7fa63700950026f40c11cd66d50c06 Mon Sep 17 00:00:00 2001 From: Luke Bakken Date: Fri, 24 Jan 2025 07:21:42 -0800 Subject: [PATCH] Allow setting TimeSpan.Zero as a heartbeat timeout value --- .../RabbitMQ.Client/Impl/SocketFrameHandler.cs | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/projects/RabbitMQ.Client/Impl/SocketFrameHandler.cs b/projects/RabbitMQ.Client/Impl/SocketFrameHandler.cs index b39b95370..4a970f00d 100644 --- 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; + } } }