lib/amq/client/async/adapters/event_machine.rb in amq-client-0.8.6 vs lib/amq/client/async/adapters/event_machine.rb in amq-client-0.8.7.pre1

- old
+ new

@@ -140,10 +140,11 @@ def initialize(*args) super(*args) self.logger = self.class.logger - @frames = Array.new + # channel => collected frames. MK. + @frames = Hash.new { Array.new } @channels = Hash.new @callbacks = Hash.new opening!