From a9ee96a320a48da81993562abb79950dfb40e82e Mon Sep 17 00:00:00 2001 From: Gabriele Santomaggio Date: Tue, 13 Jun 2023 09:29:32 +0200 Subject: [PATCH] change default log for ProcessIncomingFrames thread (#275) * In a pressure system, the process frame could take longer to close. * Increase a bit the wait time and change the log from Error to Warning because it is not an error, just a warning. Signed-off-by: Gabriele Santomaggio --- RabbitMQ.Stream.Client/Connection.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/RabbitMQ.Stream.Client/Connection.cs b/RabbitMQ.Stream.Client/Connection.cs index 47fbd410..9171b2fb 100644 --- a/RabbitMQ.Stream.Client/Connection.cs +++ b/RabbitMQ.Stream.Client/Connection.cs @@ -222,9 +222,9 @@ public void Dispose() writer.Complete(); reader.Complete(); socket.Dispose(); - if (!_incomingFramesTask.Wait(Consts.ShortWait)) + if (!_incomingFramesTask.Wait(Consts.MidWait)) { - _logger?.LogError("frame reader task did not exit in {ShortWait}", Consts.ShortWait); + _logger?.LogWarning("ProcessIncomingFrames reader task did not exit in {MidWait}", Consts.MidWait); } } finally