Class: Delayed::Lifecycle
- Inherits:
-
Object
- Object
- Delayed::Lifecycle
- Defined in:
- lib/delayed/lifecycle.rb
Constant Summary collapse
- EVENTS =
{ :error => [:worker, :job, :exception], :exceptional_exit => [:worker, :exception], :execute => [:worker], :invoke_job => [:job], :loop => [:worker], :perform => [:worker, :job], :pop => [:worker], :work_queue_pop => [:work_queue, :worker_config], :check_for_work => [:work_queue], }
Instance Method Summary collapse
- #after(event, &block) ⇒ Object
- #around(event, &block) ⇒ Object
- #before(event, &block) ⇒ Object
-
#initialize ⇒ Lifecycle
constructor
A new instance of Lifecycle.
- #reset! ⇒ Object
- #run_callbacks(event, *args, &block) ⇒ Object
Constructor Details
#initialize ⇒ Lifecycle
Returns a new instance of Lifecycle.
17 18 19 |
# File 'lib/delayed/lifecycle.rb', line 17 def initialize reset! end |
Instance Method Details
#after(event, &block) ⇒ Object
30 31 32 |
# File 'lib/delayed/lifecycle.rb', line 30 def after(event, &block) add(:after, event, &block) end |
#around(event, &block) ⇒ Object
34 35 36 |
# File 'lib/delayed/lifecycle.rb', line 34 def around(event, &block) add(:around, event, &block) end |
#before(event, &block) ⇒ Object
26 27 28 |
# File 'lib/delayed/lifecycle.rb', line 26 def before(event, &block) add(:before, event, &block) end |
#reset! ⇒ Object
21 22 23 24 |
# File 'lib/delayed/lifecycle.rb', line 21 def reset! @callbacks = EVENTS.keys.inject({}) { |hash, e| hash[e] = Callback.new; hash } Delayed::Worker.plugins.each { |plugin| plugin.reset! } end |
#run_callbacks(event, *args, &block) ⇒ Object
38 39 40 41 42 43 44 45 46 |
# File 'lib/delayed/lifecycle.rb', line 38 def run_callbacks(event, *args, &block) missing_callback(event) unless @callbacks.has_key?(event) unless EVENTS[event].size == args.size raise ArgumentError, "Callback #{event} expects #{EVENTS[event].size} parameter(s): #{EVENTS[event].join(', ')}" end @callbacks[event].execute(*args, &block) end |