Sha256: 36c3230005afc8cea0e29c34d0e019aea16f2370d4b843c01896409b60b97c72

Contents?: true

Size: 874 Bytes

Versions: 8

Compression:

Stored size: 874 Bytes

Contents

require 'ansi'
require 'yell'

module RabbitWQ
  class WorkLogger

    def initialize( log_level, path )
      @logger = Yell.new do |l|
                  l.level = log_level
                  l.adapter :file, path
                end
    end

    def level=( level )
      # conform to API but do not set log level this way
    end

    %w(
      debug
      error
      fatal
      info
      warn
    ).each do |level|

      define_method level do |*args|
        worker, message = nil, nil
        if args.size > 1
          worker, message = *args
        else
          message = args.first
        end

        if worker
          logger.send( level, "[" + ANSI.cyan { "#{worker.class.name}:#{worker.object_id}" } + "] #{message}" )
        else
          logger.send( level, message )
        end
      end

    end

  protected

    attr_reader :logger

  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
rabbit-wq-1.9.0 lib/rabbit_wq/work_logger.rb
rabbit-wq-1.8.0 lib/rabbit_wq/work_logger.rb
rabbit-wq-1.7.0 lib/rabbit_wq/work_logger.rb
rabbit-wq-1.6.3 lib/rabbit_wq/work_logger.rb
rabbit-wq-1.6.2 lib/rabbit_wq/work_logger.rb
rabbit-wq-1.6.1 lib/rabbit_wq/work_logger.rb
rabbit-wq-1.6.0 lib/rabbit_wq/work_logger.rb
rabbit-wq-1.5.0 lib/rabbit_wq/work_logger.rb