pjhyett (owner)

Fork Of

Revisions

gist: 18892 Download_button fork
public
Public Clone URL: git://gist.github.com/18892.git
Embed All Files: show embed
server.rb #
raw 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

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 #
raw 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

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