ruby and node.js message exchange via rabbitmq

amqp_consumer.rb

require 'amqp'

EventMachine.run do
  connection = AMQP.connect(:host => '127.0.0.1', :username => 'guest', :password => 'guest')
  puts "Connecting to AMQP broker. Running #{AMQP::VERSION} version of the gem..."

  channel  = AMQP::Channel.new(connection)
  queue    = channel.queue("rubyqueue", :auto_delete => true)
  exchange = channel.default_exchange

  queue.subscribe do |payload|
    puts "Received a message: #{payload}."
  end
end

amqp_producer.rb

var amqp = require('amqp');

var connection = amqp.createConnection({ host: 'localhost' });

connection.on('ready', function () {
  console.log('connected to ' + connection.serverProperties.product);
  connection.exchange('').publish('rubyqueue', 'hello from js');
});