123456789_123456789_123456789_123456789_123456789_

Class: ActiveSupport::Subscriber

Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Subclasses:
ActionController::LogSubscriber, ActionMailer::LogSubscriber, ActionView::LogSubscriber, ActiveRecord::LogSubscriber, ActiveStorage::LogSubscriber, LogSubscriber, ActiveJob::Logging::LogSubscriber, Rails::Rack::Logger
Inherits: Object
Defined in: activesupport/lib/active_support/subscriber.rb

Overview

Subscriber is an object set to consume Notifications. The subscriber dispatches notifications to a registered object based on its given namespace.

An example would be an Active Record subscriber responsible for collecting statistics about queries:

module ActiveRecord
  class StatsSubscriber < ActiveSupport::Subscriber
    attach_to :active_record

    def sql(event)
      Statsd.timing("sql.#{event.payload[:name]}", event.duration)
    end
  end
end

After configured, whenever a “sql.active_record” notification is published, it will properly dispatch the event (ActiveSupport::Notifications::Event) to the sql method.

Class Method Summary

Instance Method Summary

Constructor Details

.new ⇒ Subscriber

[ GitHub ] 

  


# File 'activesupport/lib/active_support/subscriber.rb', line 80



def initialize
  @queue_key = [self.class.name, object_id].join "-"
  @patterns  = []
  super
end


  







Class Method Details



  

    .add_event_subscriber(event)   (private)
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/subscriber.rb', line 65



def add_event_subscriber(event) # :doc:
  return if %w{ start finish }.include?(event.to_s)

  pattern = "#{event}.#{namespace}"

  # Don't add multiple subscribers (eg. if methods are redefined).
  return if subscriber.patterns.include?(pattern)

  subscriber.patterns << pattern
  notifier.subscribe(pattern, subscriber)
end


  








  

    .attach_to(namespace, subscriber = new, notifier = ActiveSupport::Notifications)  
  



  

    

Attach the subscriber to a namespace.


  



  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/subscriber.rb', line 30



def attach_to(namespace, subscriber = new, notifier = ActiveSupport::Notifications)
  @namespace  = namespace
  @subscriber = subscriber
  @notifier   = notifier

  subscribers << subscriber

  # Add event subscribers for all existing methods on the class.
  subscriber.public_methods(false).each do |event|
    add_event_subscriber(event)
  end
end


  








  

    .method_added(event)  
  



  

    

Adds event subscribers for all new methods added to the class.


  



  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/subscriber.rb', line 44



def method_added(event)
  # Only public methods are added as subscribers, and only if a notifier
  # has been set up. This means that subscribers will only be set up for
  # classes that call #attach_to.
  if public_method_defined?(event) && notifier
    add_event_subscriber(event)
  end
end


  








  

    .subscribers  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/subscriber.rb', line 53



def subscribers
  @@subscribers ||= []
end


  







Instance Method Details



  

    #finish(name, id, payload)  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/subscriber.rb', line 94



def finish(name, id, payload)
  finished  = now
  event     = event_stack.pop
  event.end = finished
  event.payload.merge!(payload)

  method = name.split(".".freeze).first
  send(method, event)
end


  








  

    #start(name, id, payload)  
  

  [ GitHub ]


  

  


# File 'activesupport/lib/active_support/subscriber.rb', line 86



def start(name, id, payload)
  e = ActiveSupport::Notifications::Event.new(name, now, nil, id, payload)
  parent = event_stack.last
  parent << e if parent

  event_stack.push e
end