Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #!/usr/bin/env ruby
- # encoding utf-8
- require 'bunny'
- STDOUT.sync = true
- conn = Bunny.new(host: 'rmq', user: 'guest', pass: 'guest')
- conn.start
- ch = conn.create_channel
- x = ch.direct('work.exchange')
- dlx = ch.direct('retry.exchange')
- target_queue = ch.queue('work.queue', arguments: {
- :'x-dead-letter-exchange' => 'retry.exchange'
- }).bind(x, routing_key: 'work.queue')
- retry_queue = ch.queue('retry.queue', arguments: {
- :'x-dead-letter-exchange' => 'work.exchange',
- :'x-message-ttl' => 60000
- }).bind(dlx, routing_key: 'work.queue')
- conn.close
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement