ActiveSupport::Notifications::Fanout

ActiveSupport::Notifications::Fanout:

Type:

Class

This is a default queue implementation that ships with Notifications. It just pushes events to all registered log subscribers.

This class is thread safe. All methods are reentrant.

wait() Instance Public methods This is a sync queue, so there is no waiting

new() Class Public methods

finish(name, id, payload) Instance Public methods

publish(name, *args) Instance Public methods

listeners_for(name) Instance Public methods

start(name, id, payload) Instance Public methods

listening?(name) Instance Public methods

subscribe(pattern = nil, block = Proc.new) Instance Public methods

unsubscribe(subscriber) Instance Public methods