Contents

module Appsignal
  class Subscriber
    attr_reader :as_subscriber

    def initialize
      subscribe
    end

    def subscribe
      Appsignal.logger.debug('Subscribing to notifications')
      # Subscribe to notifications that don't start with a !
      @as_subscriber = ActiveSupport::Notifications.subscribe(/^[^!]/, self)
    end

    def unsubscribe
      if @as_subscriber
        Appsignal.logger.debug('Unsubscribing from notifications')
        ActiveSupport::Notifications.unsubscribe(@as_subscriber)
        @as_subscriber = nil
      end
    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.nil_transaction? || transaction.paused?

      transaction.start_event
    end

    def finish(name, id, payload)
      return unless transaction = Appsignal::Transaction.current
      return if transaction.nil_transaction? || transaction.paused?

      title, body, body_format = Appsignal::EventFormatter.format(name, payload)
      transaction.finish_event(
        name,
        title,
        body,
        body_format
      )
    end
  end
end

Version data entries

36 entries across 36 versions & 1 rubygems

Version	Path
appsignal-1.2.3	lib/appsignal/subscriber.rb
appsignal-1.2.3.beta.3	lib/appsignal/subscriber.rb
appsignal-1.2.3.beta.2	lib/appsignal/subscriber.rb
appsignal-1.2.3.beta.1	lib/appsignal/subscriber.rb
appsignal-1.2.2	lib/appsignal/subscriber.rb
appsignal-1.2.1	lib/appsignal/subscriber.rb
appsignal-1.2.1.beta.3	lib/appsignal/subscriber.rb
appsignal-1.2.1.beta.2	lib/appsignal/subscriber.rb
appsignal-1.2.1.beta.1	lib/appsignal/subscriber.rb
appsignal-1.2.0	lib/appsignal/subscriber.rb
appsignal-1.2.0.beta.1	lib/appsignal/subscriber.rb
appsignal-1.2.0.alpha.6	lib/appsignal/subscriber.rb
appsignal-1.2.0.alpha.5	lib/appsignal/subscriber.rb
appsignal-1.2.0.alpha.4	lib/appsignal/subscriber.rb
appsignal-1.2.0.alpha.3	lib/appsignal/subscriber.rb
appsignal-1.2.0.alpha.2	lib/appsignal/subscriber.rb