# File lib/ruote-amqp/receiver.rb, line 68
    def initialize(engine_or_storage, opts={})

      super(engine_or_storage)
      @engine_storage = engine_or_storage
      @launchitems = opts[:launchitems]

      @queue =
        opts[:queue] ||
        @launchitems == :only ? 'ruote_launchitems' : 'ruote_workitems'

      RuoteAMQP.start!

      MQ.queue(@queue).unsubscribe # taking over...
      sleep 0.3

      MQ.queue(@queue, :durable => true).subscribe do |message|
        if AMQP.closing?
          # do nothing, we're going down
        else
          handle(message)
        end
      end
    end