public interface ManagedActorClassification
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.
Modifier and Type | Interface and Description |
---|---|
private static class |
ManagedActorClassification.ManagedActorClassificationMappings |
Modifier and Type | Method and Description |
---|---|
boolean |
associate(ActorRef monitored,
ActorRef monitor) |
ActorRef |
classify(ManagedActorClassification event)
Returns the Classifier associated with the specified Event
|
void |
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 API
|
boolean |
subscribe(ActorRef subscriber,
ActorRef to) |
ActorSystem |
system() |
boolean |
unregisterFromUnsubscriber(ActorRef subscriber,
int seqNr)
INTERNAL API
|
void |
unsubscribe(ActorRef subscriber) |
boolean |
unsubscribe(ActorRef subscriber,
ActorRef from) |
ActorRef |
unsubscriber()
The unsubscriber takes care of unsubscribing actors, which have terminated.
|
ActorSystem system()
ActorRef unsubscriber()
void dissociate(ActorRef actor)
ActorRef classify(ManagedActorClassification event)
event
- (undocumented)int mapSize()
void publish(ManagedActorClassification event)
void unsubscribe(ActorRef subscriber)
boolean registerWithUnsubscriber(ActorRef subscriber, int seqNr)
subscriber
- (undocumented)seqNr
- (undocumented)boolean unregisterFromUnsubscriber(ActorRef subscriber, int seqNr)
subscriber
- (undocumented)seqNr
- (undocumented)