Module: RabbitWQ::Worker

Defined in:
lib/rabbit_wq/worker.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(other_module) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
# 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.logger
        messages.each do |message|
          RabbitWQ.work_logger.send level, self, message
        end
      end

    end
  end
end

Instance Method Details

#with_logging ⇒ Object 



30
31
32
33
34
 
# File 'lib/rabbit_wq/worker.rb', line 30

def with_logging
  info "BEGIN #{self.class.name}"
  yield
  info "END   #{self.class.name}"
end

#work(options = {}) ⇒ Object 



25
26
27
28
 
# File 'lib/rabbit_wq/worker.rb', line 25

def work( options={} )
  RabbitWQ::Work.enqueue( self, options )
  self
end