класс ActiveSupport::Subscriber

Родитель:: Object

ActiveSupport::Subscriber — это объект, предназначенный для потребления ActiveSupport::Notifications. Подписчик рассылает уведомления зарегистрированному объекту на основе заданного имени пространства имён.

Например, подписчик Active Record, ответственный за сбор статистики о запросах:

module ActiveRecord
  class StatsSubscriber < ActiveSupport::Subscriber
    def sql(event)
      Statsd.timing("sql.#{event.payload[:name]}", event.duration)
    end
  end
end

И, наконец, он зарегистрирован как:

ActiveRecord::StatsSubscriber.attach_to :active_record

Поскольку нам нужно знать все методы экземпляра перед подключением подписчика журнала, строка выше должна вызываться после определения вашего подписчика.

После настройки, всякий раз, когда публикуется уведомление «sql.active_record», оно будет корректно отправлено (ActiveSupport::Notifications::Event) в метод sql .

Атрибуты

namespace[R]

notifier[R]

subscriber[R]

Публичные Классовые Методы

attach_to(namespace, subscriber=new, notifier=ActiveSupport::Notifications) Показать исходный код

Подключает подписчика к имени пространства.

# File activesupport/lib/active_support/subscriber.rb, line 33
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) Показать исходный код

Добавляет подписчиков на события для всех новых методов, добавленных в класс.

# File activesupport/lib/active_support/subscriber.rb, line 47
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

new() Показать исходный код

Вызывает метод суперкласса

# File activesupport/lib/active_support/subscriber.rb, line 79
def initialize
  @queue_key = [self.class.name, object_id].join "-"
  @patterns  = []
  super
end

subscribers() Показать исходный код

# File activesupport/lib/active_support/subscriber.rb, line 56
def subscribers
  @@subscribers ||= []
end

Защищенные Классовые Методы

add_event_subscriber(event) Показать исходный код

# File activesupport/lib/active_support/subscriber.rb, line 64
def add_event_subscriber(event)
  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

Публичные Методы Экземпляров

finish(name, id, payload) Показать исходный код

# File activesupport/lib/active_support/subscriber.rb, line 93
def finish(name, id, payload)
  finished  = Time.now
  event     = event_stack.pop
  event.end = finished
  event.payload.merge!(payload)

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

start(name, id, payload) Показать исходный код

# File activesupport/lib/active_support/subscriber.rb, line 85
def start(name, id, payload)
  e = ActiveSupport::Notifications::Event.new(name, Time.now, nil, id, payload)
  parent = event_stack.last
  parent << e if parent

  event_stack.push e
end