server.rb

require 'rubygems'
require 'mq'
require 'json'

EM.run do

  AMQP.start(:vhost => '/heroku',
             :user  => 'face',
             :pass  => 'thisisheroku!')

  MQ.queue('wtf').bind(MQ.topic("asdf")).subscribe do |r|
	p r
  end
end

x.rb

require 'rubygems'
require 'mq'
require 'json'

EM.run do

  AMQP.start(:vhost => '/heroku',
             :user  => 'face',
             :pass  => 'thisisheroku!')

  MQ.topic("asdf").publish({ :domain => 'asdflkasjdflkj' }.to_json)

  EM.add_timer(1) { EM.stop_event_loop }
end