Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- runThread = Thread.new do
- con = Stomp::Connection.new(connection_hash)
- con.subscribe("/queue/Regression.Run.Created")
- loop do
- msg = con.receive
- Thread.new do
- run = JSON.parse(msg.body)
- processCreatedRun(run, con)
- end
- end
- end
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement