Sample AMQP consumer/producer for RabbitMQ with direct exchange

consumer.rb

require 'amqp'

def run
  config = {
    :host => 'localhost'
  }
  AMQP.start(config) do |connection|
    channel = AMQP::Channel.new(connection)
    queue = channel.queue('', :auto_delete => true)
    exchange = channel.direct 'ex.direct'
    
    queue.bind(exchange, :routing_key => 'tasks').subscribe do |headers, payload|
      puts payload
    end
    
    stopper = Proc.new { connection.close { EventMachine.stop } }
    Signal.trap "INT", stopper
  end
end

run

producer.rb

require 'amqp'

def run
  config = {
    :host => 'localhost'
  }
  AMQP.start(config) do |connection, open_ok|
    channel = AMQP::Channel.new(connection)
    exchange = channel.direct 'ex.direct'
    msg = 'Hello, world'
    exchange.publish(msg, :routing_key => 'tasks') do
      puts "sent: #{msg}"
      connection.close { EventMachine.stop }
    end
  end
end

run