channel.rb in amq-client-0.7.0.alpha29

- old
+ new

@@ -259,9 +259,11 @@
         @queues_awaiting_unbind_ok     = Array.new
         @queues_awaiting_consume_ok    = Array.new
         @queues_awaiting_cancel_ok     = Array.new
 
         @queues_awaiting_get_response  = Array.new
+
+        @callbacks                     = Hash.new
       end # reset_state!
 
 
       def handle_connection_interruption(method = nil)
         self.reset_state!