Module: ActiveJob::Instrumentation
- Extended by:
- ActiveSupport::Concern
- Included in:
- Base
- Defined in:
- activejob/lib/active_job/instrumentation.rb
Overview
:nodoc:
Instance Method Summary collapse
Methods included from ActiveSupport::Concern
append_features, class_methods, extended, included, prepend_features, prepended
Instance Method Details
#instrument(operation, payload = {}, &block) ⇒ Object
:nodoc:
29 30 31 32 33 34 35 36 37 38 39 |
# File 'activejob/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 'activejob/lib/active_job/instrumentation.rb', line 25 def perform_now instrument(:perform) { super } end |