11 lines
298 B
Ruby
11 lines
298 B
Ruby
|
require 'rubygems'
|
||
|
|
require 'stomp'
|
||
|
|
|
||
|
|
conn = Stomp::Connection.open("guest", "guest", "localhost")
|
||
|
|
conn.subscribe '/queue/rpc-service'
|
||
|
|
while mesg = conn.receive
|
||
|
|
puts "received message and replies to #{mesg.headers['reply-to']}"
|
||
|
|
|
||
|
|
conn.publish(mesg.headers['reply-to'], '(reply) ' + mesg.body)
|
||
|
|
end
|