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