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