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