# File lib/amqp/queue.rb, line 68 def initialize(mq, name, opts = {}, &block) @mq = mq @opts = self.class.add_default_options(name, opts, block) @bindings ||= {} @name = name unless name.empty? @status = @opts[:nowait] ? :unknown : :unfinished @mq.callback { @mq.send Protocol::Queue::Declare.new(@opts) } self.callback = block block.call(self) if @opts[:nowait] && block end