diff --git a/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs b/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs
index 72e6ad84..973cc103 100644
--- a/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs
+++ b/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs
@@ -70,8 +70,10 @@ IPooledObjectPolicy<IModel> _objectPolicy
 
             _subConnection = factory.CreateConnection();
 
-            _pubChannelPool = new DefaultObjectPool<IModel>(_objectPolicy);
-            
+            var provider = new DefaultObjectPoolProvider();
+
+            _pubChannelPool = provider.Create(_objectPolicy);
+
             _busId = Guid.NewGuid().ToString("N");
 
             BusName = "easycachingbus";