summaryrefslogtreecommitdiff
path: root/deps/rabbitmq_stomp/examples/ruby/exchange-receiver.rb
diff options
context:
space:
mode:
Diffstat (limited to 'deps/rabbitmq_stomp/examples/ruby/exchange-receiver.rb')
-rw-r--r--deps/rabbitmq_stomp/examples/ruby/exchange-receiver.rb15
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