|
require 'rubygems'
|
|
require 'stomp'
|
|
|
|
conn = Stomp::Connection.open("guest", "guest", "localhost")
|
|
conn.subscribe '/exchange/amq.fanout/test'
|
|
|
|
puts "Waiting for messages..."
|
|
|
|
begin
|
|
while mesg = conn.receive
|
|
puts mesg.body
|
|
end
|
|
rescue Exception => _
|
|
conn.disconnect
|
|
end
|