Module: ActiveJob::Instrumentation

Extended by:
ActiveSupport::Concern
Included in:
Base
Defined in:
lib/active_job/instrumentation.rb

Overview

:nodoc:

Instance Method Summary collapse

Instance Method Details

#instrument(operation, payload = {}, &block) ⇒ Object

:nodoc:



29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/active_job/instrumentation.rb', line 29

def instrument(operation, payload = {}, &block) # :nodoc:
  payload[:job] = self
  payload[:adapter] = queue_adapter

  ActiveSupport::Notifications.instrument("#{operation}.active_job", payload) do |payload|
    value = block.call(payload) if block
    payload[:aborted] = @_halted_callback_hook_called if defined?(@_halted_callback_hook_called)
    @_halted_callback_hook_called = nil
    value
  end
end

#perform_now ⇒ Object 



25
26
27
 
# File 'lib/active_job/instrumentation.rb', line 25

def perform_now
  instrument(:perform) { super }
end