amqp agent

agent.rb

require "bunny"

# Start a communication session with RabbitMQ
conn = Bunny.new
conn.start

ch = conn.create_channel
q  = ch.queue("test1")

loop do
  delivery_info, metadata, payload = q.pop

  if payload
    puts "Scan: #{payload}"
  end

  sleep 1
end

conn.stop