From facb8dfb9a2767ad656363bd05bb7ce9d472a86e Mon Sep 17 00:00:00 2001 From: liangshiwei Date: Tue, 11 Feb 2025 16:27:08 +0800 Subject: [PATCH] Update ChannelPool.cs --- framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/ChannelPool.cs | 1 + 1 file changed, 1 insertion(+) diff --git a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/ChannelPool.cs b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/ChannelPool.cs index 85a11a0961..b7ed4c80c8 100644 --- a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/ChannelPool.cs +++ b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/ChannelPool.cs @@ -44,6 +44,7 @@ public class ChannelPool : IChannelPool, ISingletonDependency if (poolItem.Channel.IsClosed) { + poolItem.Dispose(); Channels.TryRemove(channelName, out _); poolItem = Channels.GetOrAdd( channelName,