Sha256: 9bb620980ed2ad3094bc3511b5c528ef518876ae8f42e00435e1a7628e45d2b7
Contents?: true
Size: 1.53 KB
Versions: 9
Compression:
Stored size: 1.53 KB
Contents
require 'celluloid'
$CELLULOID_MONITORING = true
module Celluloid
class Probe
include Celluloid
include Celluloid::Notifications
NOTIFICATIONS_TOPIC_BASE = 'celluloid.events.%s'
INITIAL_EVENTS = Queue.new
class << self
def run
# spawn the actor if not found
supervise_as(:probe_actor) unless Actor[:probe_actor] && Actor[:probe_actor].alive?
end
def actor_created(actor)
trigger_event(:actor_created, actor)
end
def actor_named(actor)
trigger_event(:actor_named, actor)
end
def actor_died(actor)
trigger_event(:actor_died, actor)
end
def actors_linked(a, b)
a = find_actor(a)
b = find_actor(b)
trigger_event(:actors_linked, a, b)
end
private
def trigger_event(name, *args)
return unless $CELLULOID_MONITORING
probe_actor = Actor[:probe_actor]
if probe_actor
probe_actor.async.dispatch_event(name, args)
else
INITIAL_EVENTS << [name, args]
end
end
def find_actor(obj)
if obj.__send__(:class) == Actor
obj
elsif owner = obj.instance_variable_get(OWNER_IVAR)
owner
end
end
end
def initialize
async.first_run
end
def first_run
until INITIAL_EVENTS.size == 0
event = INITIAL_EVENTS.pop
dispatch_event(*event)
end
end
def dispatch_event(cmd, args)
publish(NOTIFICATIONS_TOPIC_BASE % cmd, args)
end
end
end
Version data entries
9 entries across 7 versions & 4 rubygems