Advertisement
Guest User

Untitled

a guest
Aug 3rd, 2012
61
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.29 KB | None | 0 0
  1. runThread = Thread.new do
  2. con = Stomp::Connection.new(connection_hash)
  3.  
  4. con.subscribe("/queue/Regression.Run.Created")
  5. loop do
  6. msg = con.receive
  7. Thread.new do
  8. run = JSON.parse(msg.body)
  9. processCreatedRun(run, con)
  10. end
  11. end
  12. end
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement