Package org.apache.pekko.event
Interface ManagedActorClassification
-
public interface ManagedActorClassificationMaps ActorRefs to ActorRefs to form an EventBus where ActorRefs can listen to other ActorRefs.All subscribers will be watched by an
org.apache.pekko.event.ActorClassificationUnsubscriberand 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 booleanassociate(ActorRef monitored, ActorRef monitor)ActorRefclassify(ManagedActorClassification event)Returns the Classifier associated with the specified Eventvoiddissociate(ActorRef actor)booleandissociate(ActorRef monitored, ActorRef monitor)intmapSize()This is a size hint for the number of Classifiers you expect to have (use powers of 2)voidpublish(ManagedActorClassification event)booleanregisterWithUnsubscriber(ActorRef subscriber, int seqNr)INTERNAL APIbooleansubscribe(ActorRef subscriber, ActorRef to)ActorSystemsystem()booleanunregisterFromUnsubscriber(ActorRef subscriber, int seqNr)INTERNAL APIvoidunsubscribe(ActorRef subscriber)booleanunsubscribe(ActorRef subscriber, ActorRef from)ActorRefunsubscriber()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.
-
-