module Celluloid::Notifications
Public Class Methods
notifier()
click to toggle source
# File lib/celluloid/notifications.rb, line 3 def self.notifier Actor[:notifications_fanout] or raise DeadActorError, "notifications fanout actor not running" end
Public Instance Methods
publish(pattern, *args)
click to toggle source
# File lib/celluloid/notifications.rb, line 7 def publish(pattern, *args) Celluloid::Notifications.notifier.publish(pattern, *args) end
subscribe(pattern, method)
click to toggle source
# File lib/celluloid/notifications.rb, line 11 def subscribe(pattern, method) Celluloid::Notifications.notifier.subscribe(Actor.current, pattern, method) end
unsubscribe(*args)
click to toggle source
# File lib/celluloid/notifications.rb, line 15 def unsubscribe(*args) Celluloid::Notifications.notifier.unsubscribe(*args) end