rabbitmq-server/deps/rabbitmq_stomp/examples/ruby/topic-broadcast-receiver.rb

require 'rubygems'
require 'stomp'

topic = ARGV[0] || 'x'
puts "Binding to /topic/#{topic}"

conn = Stomp::Connection.open('guest', 'guest', 'localhost')
conn.subscribe("/topic/#{topic}")
while mesg = conn.receive
  puts mesg.body
end
Support binding during SUBSCRIBE. (Thanks to Artur Bergman) 2008-06-16 23:39:29 +08:00			`require 'rubygems'`
			`require 'stomp'`

Reworked Ruby examples to allow more flexibility in the topic examples. Still need to document this 2011-01-04 18:19:54 +08:00			`topic = ARGV[0] \|\| 'x'`
			`puts "Binding to /topic/#{topic}"`

Support binding during SUBSCRIBE. (Thanks to Artur Bergman) 2008-06-16 23:39:29 +08:00			`conn = Stomp::Connection.open('guest', 'guest', 'localhost')`
Reworked Ruby examples to allow more flexibility in the topic examples. Still need to document this 2011-01-04 18:19:54 +08:00			`conn.subscribe("/topic/#{topic}")`
Correct termination condition in Ruby examples 2008-07-16 18:09:30 +08:00			`while mesg = conn.receive`
			`puts mesg.body`
Support binding during SUBSCRIBE. (Thanks to Artur Bergman) 2008-06-16 23:39:29 +08:00			`end`