diff options
Diffstat (limited to 'deps/rabbitmq_stomp/examples/ruby/temp-queue-service.rb')
| -rw-r--r-- | deps/rabbitmq_stomp/examples/ruby/temp-queue-service.rb | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/deps/rabbitmq_stomp/examples/ruby/temp-queue-service.rb b/deps/rabbitmq_stomp/examples/ruby/temp-queue-service.rb new file mode 100644 index 0000000000..fea4fa7803 --- /dev/null +++ b/deps/rabbitmq_stomp/examples/ruby/temp-queue-service.rb @@ -0,0 +1,15 @@ +require 'rubygems' +require 'stomp' + +conn = Stomp::Connection.open("guest", "guest", "localhost") +conn.subscribe '/queue/rpc-service' + +begin + while mesg = conn.receive + puts "received message and replies to #{mesg.headers['reply-to']}" + + conn.publish(mesg.headers['reply-to'], '(reply) ' + mesg.body) + end +rescue Exception => _ + conn.disconnect +end |