class ActiveSupport::Notifications::Instrumenter
Instrumenters are stored in a thread local.
def finish(name, payload)
def finish(name, payload) @notifier.finish name, @id, payload end
def finish_with_state(listeners_state, name, payload)
def finish_with_state(listeners_state, name, payload) @notifier.finish name, @id, payload, listeners_state end
def initialize(notifier)
def initialize(notifier) @id = unique_id @notifier = notifier end
def instrument(name, payload = {})
notifier. Notice that events get sent even if an error occurs in the
and publish it. Without a block, simply send a message via the
Given a block, instrument it by measuring the time taken to execute
def instrument(name, payload = {}) # some of the listeners might have state listeners_state = start name, payload begin yield payload if block_given? rescue Exception => e payload[:exception] = [e.class.name, e.message] payload[:exception_object] = e raise e ensure finish_with_state listeners_state, name, payload end end
def new_event(name, payload = {}) # :nodoc:
def new_event(name, payload = {}) # :nodoc: Event.new(name, nil, nil, @id, payload) end
def start(name, payload)
def start(name, payload) @notifier.start name, @id, payload end
def unique_id
def unique_id SecureRandom.hex(10) end