dispose resource when connection pool is full

25ff7a68 · Savorboard · 815e16f5 · 25ff7a68
Commit 25ff7a68 authored Nov 08, 2017 by Savorboard
Show whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

PublishQueueExecutor.cs src/DotNetCore.CAP.RabbitMQ/PublishQueueExecutor.cs +3 -1

No files found.
--- a/src/DotNetCore.CAP.RabbitMQ/PublishQueueExecutor.cs
+++ b/src/DotNetCore.CAP.RabbitMQ/PublishQueueExecutor.cs
@@ -53,7 +53,9 @@ namespace DotNetCore.CAP.RabbitMQ
            }
            finally
            {
-                _connectionChannelPool.Return(channel);
+                var returned = _connectionChannelPool.Return(channel);
+                if (!returned)
+                    channel.Dispose();
            }
        }
    }