# File lib/nanite/amqp.rb, line 6 def initialize mq, name, opts = {} @mq = mq @opts = opts @bindings ||= {} @mq.queues[@name = name] ||= self @mq.callback{ @mq.send Protocol::Queue::Declare.new({ :queue => name, :nowait => true }.merge(opts)) } unless opts[:no_declare] end