rabbitmq-server/deps/rabbitmq_stomp/examples/ruby/persistent-receiver.rb

14 lines
302 B
Ruby
Raw Normal View History

2008-06-01 18:38:18 +08:00
require 'rubygems'
require 'stomp'
conn = Stomp::Connection.open('guest', 'guest', 'localhost')
#conn.subscribe('/queue/durable', :'auto-delete' => false, :durable => true)
conn.subscribe('/queue/durable')
puts "Waiting for messages..."
while true
mesg = conn.receive
puts mesg.body if mesg
end