# File lib/amqp/channel.rb, line 826 def queue!(name, opts = {}, &block) queue = if block.nil? Queue.new(self, name, opts) else shim = Proc.new { |q, method| queue = find_queue(method.queue) if block.arity == 1 block.call(queue) else block.call(queue, method.consumer_count, method.message_count) end } Queue.new(self, name, opts, &shim) end register_queue(queue) end