logging for notwife

logging.rb

# vim:fileencoding=utf-8
require 'logger'
require 'rubygems'
require 'bundler'
Bundler.setup(:processor)

require 'mq'

logger = Logger.new(ARGV[0]||STDOUT,20,1048576 * 20)
logger.info "Start"

AMQP.start do
  amq = MQ.new
  queue = amq.queue('logging').bind(amq.fanout('stream'))
  queue.subscribe do |msg|
    logger.info msg
  end
  trap("TERM") {
    logger.warn "Finish"
    queue.delete
    AMQP.stop {EM.stop}
  }
  trap("INT")  {
    logger.warn "Finish"
    queue.delete
    AMQP.stop {EM.stop}
  }
end