Package akka.event
Interface ManagedActorClassification
-
public interface ManagedActorClassification
Maps ActorRefs to ActorRefs to form an EventBus where ActorRefs can listen to other ActorRefs.All subscribers will be watched by an
akka.event.ActorClassificationUnsubscriber
and unsubscribed when they terminate. The unsubscriber actor will not be stopped automatically, and if you want to stop using the bus you should stop it yourself.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description boolean
associate(ActorRef monitored, ActorRef monitor)
ActorRef
classify(ManagedActorClassification event)
Returns the Classifier associated with the specified Eventvoid
dissociate(ActorRef actor)
boolean
dissociate(ActorRef monitored, ActorRef monitor)
int
mapSize()
This is a size hint for the number of Classifiers you expect to have (use powers of 2)void
publish(ManagedActorClassification event)
boolean
registerWithUnsubscriber(ActorRef subscriber, int seqNr)
INTERNAL APIboolean
subscribe(ActorRef subscriber, ActorRef to)
ActorSystem
system()
boolean
unregisterFromUnsubscriber(ActorRef subscriber, int seqNr)
INTERNAL APIvoid
unsubscribe(ActorRef subscriber)
boolean
unsubscribe(ActorRef subscriber, ActorRef from)
ActorRef
unsubscriber()
The unsubscriber takes care of unsubscribing actors, which have terminated.
-
-
-
Method Detail
-
classify
ActorRef classify(ManagedActorClassification event)
Returns the Classifier associated with the specified Event
-
dissociate
void dissociate(ActorRef actor)
-
mapSize
int mapSize()
This is a size hint for the number of Classifiers you expect to have (use powers of 2)
-
publish
void publish(ManagedActorClassification event)
-
registerWithUnsubscriber
boolean registerWithUnsubscriber(ActorRef subscriber, int seqNr)
INTERNAL API
-
system
ActorSystem system()
-
unregisterFromUnsubscriber
boolean unregisterFromUnsubscriber(ActorRef subscriber, int seqNr)
INTERNAL API
-
unsubscribe
void unsubscribe(ActorRef subscriber)
-
unsubscriber
ActorRef unsubscriber()
The unsubscriber takes care of unsubscribing actors, which have terminated.
-
-