lib/amqp/channel.rb in amqp-0.9.1 vs lib/amqp/channel.rb in amqp-0.9.2

- old
+ new

@@ -263,9 +263,10 @@ self.open do @channel_is_open_deferrable.succeed # exchanges must be recovered first because queue recovery includes recovery of bindings. MK. + @exchanges.each { |name, e| e.auto_recover } @queues.each { |name, q| q.auto_recover } end end # auto_recover # Can be used to recover channels from channel-level exceptions. Allocates a new channel id and reopens