Update ChannelPool.cs

2 years ago · facb8dfb9a
1 changed files with 1 additions and 0 deletions
--- 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,