Small Rabbit Consumer Test

gistfile1.rb

#!/usr/bin/env ruby
# encoding: utf-8

require "bunny"

conn = Bunny.new vhost: '/boxes', user: 'boxes', pass: 'xxx', host: '127.0.0.1'
conn.start

ch  = conn.create_channel
x   = ch.topic("boxes", durable: true)
q   = ch.queue("", durable: true, auto_delete: false)

q.bind(x, :routing_key => '123456')

puts " [*] Waiting for logs. To exit press CTRL+C"

begin
  q.subscribe(:block => true) do |delivery_info, properties, body|
    puts " [x] #{delivery_info.routing_key}:#{body}"
  end
rescue Interrupt => _
  ch.close
  conn.close
end