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!