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.

new() Class Public methods

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

listeners_for(name) Instance Public methods

publish(name, *args) Instance Public methods

finish(name, id, payload) 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