AMQP client implementation in Ruby/EventMachine