Skip to content
This repository has been archived by the owner on Sep 11, 2022. It is now read-only.

Commit

Permalink
Bring back a line that recovers exchanges. It was accidentally remove…
Browse files Browse the repository at this point in the history
…d in 80a8661.
  • Loading branch information
michaelklishin committed Jan 24, 2012
1 parent 7ff3a38 commit d1fc603
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion lib/amqp/channel.rb
Expand Up @@ -265,7 +265,7 @@ def auto_recover
@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 }
@exchanges.each { |name, e| e.auto_recover }
@queues.each { |name, q| q.auto_recover }
end
end # auto_recover
Expand Down

0 comments on commit d1fc603

Please sign in to comment.