Sha256: c15978c1f83d758b8774f1e428f231b34215799a54c3f6093d9df151fd0dee2f
Contents?: true
Size: 1.42 KB
Versions: 33
Compression:
Stored size: 1.42 KB
Contents
module Appsignal
class Subscriber
BLANK = ''.freeze
def initialize
subscribe
end
def subscribe
Appsignal.logger.debug('Subscribing to notifications')
# Subscribe to notifications that don't start with a !
ActiveSupport::Notifications.subscribe(/^[^!]/, self)
end
def unsubscribe
Appsignal.logger.debug('Unsubscribing from notifications')
ActiveSupport::Notifications.unsubscribe(self)
end
def resubscribe
Appsignal.logger.debug('Resubscribing to notifications')
unsubscribe
subscribe
end
def publish(name, *args)
# Not used, it's part of AS notifications but is not used in Rails
# and it seems to be unclear what it's function is. See:
# https://github.com/rails/rails/blob/master/activesupport/lib/active_support/notifications/fanout.rb#L49
end
def start(name, id, payload)
return unless transaction = Appsignal::Transaction.current
return if transaction.paused?
Appsignal::Extension.start_event(transaction.transaction_index)
end
def finish(name, id, payload)
return unless transaction = Appsignal::Transaction.current
return if transaction.paused?
title, body = Appsignal::EventFormatter.format(name, payload)
Appsignal::Extension.finish_event(
transaction.transaction_index,
name,
title || BLANK,
body || BLANK
)
end
end
end
Version data entries
33 entries across 33 versions & 1 rubygems