Skip to content

Commit

Permalink
change default log for ProcessIncomingFrames thread (#275)
Browse files Browse the repository at this point in the history
* 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 <[email protected]>
  • Loading branch information
Gsantomaggio authored Jun 13, 2023
1 parent b6fa21e commit a9ee96a
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions RabbitMQ.Stream.Client/Connection.cs
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit a9ee96a

Please sign in to comment.