blob: fea4fa7803b237ef4063525a4957454b4f172c2e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
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
|
