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