channel.rb in bunny-0.9.7

- old
+ new

@@ -1,7 +1,8 @@
 # -*- coding: utf-8 -*-
 require "thread"
+require "monitor"
 require "set"
 
 require "bunny/consumer_work_pool"
 
 require "bunny/exchange"
@@ -171,13 +172,13 @@
       @exchanges  = Hash.new
       @consumers  = Hash.new
       @work_pool  = work_pool
 
       # synchronizes frameset delivery. MK.
-      @publishing_mutex = Mutex.new
-      @consumer_mutex   = Mutex.new
+      @publishing_mutex = @connection.mutex_impl.new
+      @consumer_mutex   = @connection.mutex_impl.new
 
-      @unconfirmed_set_mutex = Mutex.new
+      @unconfirmed_set_mutex = @connection.mutex_impl.new
 
       self.reset_continuations
 
       # threads awaiting on continuations. Used to unblock
       # them when network connection goes down so that busy loops