lib/amqp/channel.rb in amqp-0.9.0.pre3 vs lib/amqp/channel.rb in amqp-0.9.0

- old
+ new

@@ -263,10 +263,9 @@ 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| puts("Recovering ex #{name}"); 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