lib/bunny/session.rb in garaio_bunny-2.19.1 vs lib/bunny/session.rb in garaio_bunny-2.19.2

@@ -378,10 +378,14 @@
 
       @channel_mutex.synchronize do
         if n && (ch = @channels[n])
           ch
         else
-          ch = Bunny::Channel.new(self, n, ConsumerWorkPool.new(consumer_pool_size || 1, consumer_pool_abort_on_exception, consumer_pool_shutdown_timeout))
+          work_pool = ConsumerWorkPool.new(consumer_pool_size || 1,
+                                           consumer_pool_abort_on_exception,
+                                           consumer_pool_shutdown_timeout,
+                                           logger: logger)
+          ch = Bunny::Channel.new(self, n, work_pool)
           ch.open
           ch
         end
       end
     end