From 1e676e4593b77450a92faa56f90640e702b89e04 Mon Sep 17 00:00:00 2001 From: Patrik Tiainen Date: Tue, 9 Dec 2025 09:51:11 +0100 Subject: [PATCH] Added TryComplete instead of comple during channel shutdown --- .../ConsumerDispatching/ConsumerDispatcherChannelBase.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs b/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs index be9ebf802..9c807d3b2 100644 --- a/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs +++ b/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs @@ -228,7 +228,7 @@ protected sealed override void ShutdownConsumer(IAsyncBasicConsumer consumer, Sh protected override Task InternalShutdownAsync() { - _writer.Complete(); + _writer.TryComplete(); return _worker; }