diff options
Diffstat (limited to 'deps/rabbitmq_stomp/examples/ruby/exchange-receiver.rb')
-rw-r--r-- | deps/rabbitmq_stomp/examples/ruby/exchange-receiver.rb | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/deps/rabbitmq_stomp/examples/ruby/exchange-receiver.rb b/deps/rabbitmq_stomp/examples/ruby/exchange-receiver.rb new file mode 100644 index 0000000000..76bf4a5c9d --- /dev/null +++ b/deps/rabbitmq_stomp/examples/ruby/exchange-receiver.rb @@ -0,0 +1,15 @@ +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 |