diff --git a/src/DotNetCore.CAP.RabbitMQ/PublishQueueExecutor.cs b/src/DotNetCore.CAP.RabbitMQ/PublishQueueExecutor.cs
index c7e828f..3f0045e 100644
--- 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();
             }
         }
     }