lib/amqp-spec/amqp.rb in amqp-spec-0.2.6 vs lib/amqp-spec/amqp.rb in amqp-spec-0.2.7

@@ -22,11 +22,11 @@
   end
 
   # Cleans up AMQP state after AMQP connection closes
   def self.cleanup_state
 #   MQ.reset ?
-    Thread.current[:mq]    = nil
-    Thread.current[:mq_id] = nil
+    Thread.list.each {|thread| thread[:mq] = nil }
+    Thread.list.each {|thread| thread[:mq_id] = nil }
     @conn                  = nil
     @closing               = false
   end
 end
\ No newline at end of file