Advertisement
Guest User

Untitled

a guest
Jul 7th, 2017
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.57 KB | None | 0 0
  1. require 'bunny'
  2.  
  3. STDOUT.sync = true
  4.  
  5. conn = Bunny.new(
  6. host: 'mq.betradar.com',
  7. vhost: '/unifiedfeed/XXXXX',
  8. port: 5671,
  9. user: 'XXXXXXXXXXXXXXXXX',
  10. password: "",
  11. ssl: true,
  12. verify_peer: false,
  13. verify_peer_name: false,
  14. allow_self_signed: true
  15. )
  16. conn.start
  17. puts conn.exchange_exists?("unifiedfeed")
  18.  
  19. ch = conn.create_channel
  20.  
  21. queue = ch.queue("", exclusive: true)
  22. queue = ch.queue("", exclusive: true)
  23. exchange = ch.direct("unifiedfeed")
  24. queue.bind(exchange)
  25.  
  26. q.subscribe do |delivery_info, metadata, payload|
  27. puts "Received #{payload}"
  28. end
  29.  
  30. sleep 1.0
  31. conn.close
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement