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

Commit

Permalink
Only find queue instance in the channel cache when queue.declare-ok i…
Browse files Browse the repository at this point in the history
…s present (this is not the case when :nowait is used)
  • Loading branch information
michaelklishin committed Feb 15, 2012
1 parent da7dfbe commit b2e76cc
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions lib/amqp/channel.rb
Expand Up @@ -828,10 +828,10 @@ def queue!(name, opts = {}, &block)
Queue.new(self, name, opts)
else
shim = Proc.new { |q, method|
queue = find_queue(method.queue)
if block.arity == 1
block.call(queue)
block.call(q)
else
queue = find_queue(method.queue)
block.call(queue, method.consumer_count, method.message_count)
end
}
Expand Down

0 comments on commit b2e76cc

Please sign in to comment.