Module: Resque::JobChain::Observable

Defined in:
lib/resque/job_chain/observable.rb

Class Method Summary collapse

Class Method Details

.log_event(event, args) ⇒ Object 



13
14
15
16
17
18
 
# File 'lib/resque/job_chain/observable.rb', line 13

def log_event(event, args)
  logger = JobChain.configuration.logger
  return unless logger

  logger.info("[resque-job-chain] #{event}: #{args.inspect}")
end

.notify(event, *args) ⇒ Object 



6
7
8
9
10
11
 
# File 'lib/resque/job_chain/observable.rb', line 6

def notify(event, *args)
  listeners = JobChain.configuration.observers_for(event)
  listeners.each { |listener| listener.call(*args) }

  log_event(event, args)
end