module RabbitWQ::Worker

Public Class Methods

included( other_module ) click to toggle source
# File lib/rabbit_wq/worker.rb, line 4
def self.included( other_module )
  other_module.class_eval do
    %w(
      debug
      error
      fatal
      info
      warn
    ).each do |level|

      define_method level do |*messages|
        return unless RabbitWQ.work_logger

        messages.each do |message|
          RabbitWQ.work_logger.send level, self, message
        end
      end

    end
  end
end

Public Instance Methods

enabled?() click to toggle source
# File lib/rabbit_wq/worker.rb, line 37
def enabled?
  true
end
error_on_disabled?() click to toggle source

When true, will place the worker in error queue

# File lib/rabbit_wq/worker.rb, line 47
def error_on_disabled?
  false
end
final_error( msg, level=:error ) click to toggle source
# File lib/rabbit_wq/worker.rb, line 41
def final_error( msg, level=:error )
  raise RabbitWQ::FinalError.new( level ), msg
end
with_logging() { || ... } click to toggle source
# File lib/rabbit_wq/worker.rb, line 31
def with_logging
  info "BEGIN #{self.class.name}"
  yield
  info "END   #{self.class.name}"
end
work( options={} ) click to toggle source
# File lib/rabbit_wq/worker.rb, line 26
def work( options={} )
  RabbitWQ::Work.enqueue( self, options )
  self
end