Simple RabbitMQ message listener

event-listener

#!/usr/bin/env ruby
require "bunny"

abort "Usage: #{$0} BINDING_KEY [BINDING_KEY, ...]" if ARGV.empty?

conn = Bunny.new("amqp://development.vm:5672")
conn.start

channel  = conn.create_channel
exchange = channel.exchange("event", no_declare: true)
queue    = channel.queue("", exclusive: true, auto_delete: true)
ARGV.each { |key| queue.bind(exchange, :routing_key => key) }

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