Basically 'cat' over AMQP to demonstrate exchanges and routing keys

consumer.rb

require 'rubygems' 
require 'bundler'
Bundler.require(:default)

Bunny.run(ENV['AMQP_URL']) do |conn|
  routing_key = 'test.demonstration'

  conn.with_channel do |ch|
    queue = ch.queue('composinator.test.demonstration')
    exchange = ch.direct('composinator')
    queue.bind(exchange, routing_key: routing_key)
    queue.subscribe(block: true) do |delivery_info, properties, payload|
      puts payload
    end
  end
end

publisher.rb

require 'rubygems' 
require 'bundler'
Bundler.require(:default)

Bunny.run(ENV['AMQP_URL']) do |conn|
  routing_key = 'test.demonstration'

  conn.with_channel do |ch|
    exchange = ch.direct('composinator')
    STDIN.each_line do |message|
      exchange.publish(message, routing_key: routing_key)
    end
  end
end