Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- require 'bunny'
- STDOUT.sync = true
- conn = Bunny.new(
- host: 'mq.betradar.com',
- vhost: '/unifiedfeed/XXXXX',
- port: 5671,
- user: 'XXXXXXXXXXXXXXXXX',
- password: "",
- ssl: true,
- verify_peer: false,
- verify_peer_name: false,
- allow_self_signed: true
- )
- conn.start
- puts conn.exchange_exists?("unifiedfeed")
- ch = conn.create_channel
- queue = ch.queue("", exclusive: true)
- queue = ch.queue("", exclusive: true)
- exchange = ch.direct("unifiedfeed")
- queue.bind(exchange)
- q.subscribe do |delivery_info, metadata, payload|
- puts "Received #{payload}"
- end
- sleep 1.0
- conn.close
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement