Thin, Sinatra, AMQP

launch.sh

#!/bin/bash
thin start -p 3000 -R test.ru 

test.ru

require "sinatra/base"
require "amqp"

class Test < Sinatra::Base

  def amqp &blk
    if ! AMQP.connection
      AMQP.connection = AMQP.connect "amqp://myAMQPserver.com"
    end
    if ! AMQP.connection.connected?
      AMQP.connection.register_connection_callback do
        raise "Error couldn't connect" unless AMQP.connection.connected?
        blk.()
      end
    else
      blk.()
    end
  end

  get "/" do
    amqp do
      p "publishing"
      MQ.queue("test_thin_sinatra_AMQP", :durable => true).publish("coucou")
    end

    "o/"
  end
end

run Test.new