gistfile1.rb

    # Ensure the AMQP connection is started
    def start!
      return if started?

      Thread.main[:ruote_amqp_connection] = Thread.new do
        Thread.abort_on_exception = true
        AMQP.start { RuoteAMQP.started! }
      end

      sleep 0.001 until RuoteAMQP.started?

      MQ.prefetch(1)
    end

    # Check whether the AMQP connection is started
    def started?
      Thread.main[:ruote_amqp_started] == true
    end

    def started! #:nodoc:
      Thread.main[:ruote_amqp_started] = true
    end

    # Close down the AMQP connections
    def stop!
      AMQP.stop
      Thread.main[:ruote_amqp_connection].join
      Thread.main[:ruote_amqp_started] = false
    end