rabbitmq-server/deps/rabbitmq_stomp/examples/ruby/temp-queue-client.rb

10 lines
227 B
Ruby

require 'rubygems'
require 'stomp'
conn = Stomp::Connection.open("guest", "guest", "localhost")
conn.publish("/queue/rpc-service", "test message", {
'reply-to' => '/temp-queue/test'
})
puts conn.receive.body
conn.disconnect