Sha256: 17bbf1323c0fcb13b397c6d3cc4ecd4365e64269432b014c3a463e2efbdbc0d9
Contents?: true
Size: 1.08 KB
Versions: 19
Compression:
Stored size: 1.08 KB
Contents
$:.unshift File.dirname(__FILE__) + '/../../lib'
require 'mq'
AMQP.start(:host => 'localhost') do
def log *args
p [ Time.now, *args ]
end
# AMQP.logging = true
amq = MQ.new
EM.add_periodic_timer(1){
puts
log :sending, 'ping'
amq.queue('one').publish('ping')
}
amq = MQ.new
amq.queue('one').subscribe{ |msg|
log 'one', :received, msg, :sending, 'pong'
amq.queue('two').publish('pong')
}
amq = MQ.new
amq.queue('two').subscribe{ |msg|
log 'two', :received, msg
}
end
__END__
[Sun Jul 20 03:52:24 -0700 2008, :sending, "ping"]
[Sun Jul 20 03:52:24 -0700 2008, "one", :received, "ping", :sending, "pong"]
[Sun Jul 20 03:52:24 -0700 2008, "two", :received, "pong"]
[Sun Jul 20 03:52:25 -0700 2008, :sending, "ping"]
[Sun Jul 20 03:52:25 -0700 2008, "one", :received, "ping", :sending, "pong"]
[Sun Jul 20 03:52:25 -0700 2008, "two", :received, "pong"]
[Sun Jul 20 03:52:26 -0700 2008, :sending, "ping"]
[Sun Jul 20 03:52:26 -0700 2008, "one", :received, "ping", :sending, "pong"]
[Sun Jul 20 03:52:26 -0700 2008, "two", :received, "pong"]
Version data entries
19 entries across 19 versions & 6 rubygems