Package akka.event.japi
Class ManagedActorEventBus<E>
- java.lang.Object
-
- akka.event.japi.ManagedActorEventBus<E>
-
public abstract class ManagedActorEventBus<E> extends java.lang.Object implements EventBus<E,ActorRef,ActorRef>
Java API: See documentation forManagedActorClassification
An EventBus where the Subscribers are ActorRefs and the Classifier is ActorRef Means that ActorRefs "listen" to other ActorRefs E is the Event type
-
-
Constructor Summary
Constructors Constructor Description ManagedActorEventBus(ActorSystem system)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract ActorRef
classify(E event)
Returns the Classifier associated with the given Eventprotected abstract int
mapSize()
This is a size hint for the number of Classifiers you expect to have (use powers of 2)void
publish(E event)
Publishes the specified Event to this busboolean
subscribe(ActorRef subscriber, ActorRef to)
Attempts to register the subscriber to the specified Classifiervoid
unsubscribe(ActorRef subscriber)
Attempts to deregister the subscriber from all Classifiers it may be subscribed toboolean
unsubscribe(ActorRef subscriber, ActorRef from)
Attempts to deregister the subscriber from the specified Classifier
-
-
-
Constructor Detail
-
ManagedActorEventBus
public ManagedActorEventBus(ActorSystem system)
-
-
Method Detail
-
classify
protected abstract ActorRef classify(E event)
Returns the Classifier associated with the given Event
-
mapSize
protected abstract int mapSize()
This is a size hint for the number of Classifiers you expect to have (use powers of 2)
-
publish
public void publish(E event)
Description copied from interface:EventBus
Publishes the specified Event to this bus
-
subscribe
public boolean subscribe(ActorRef subscriber, ActorRef to)
Description copied from interface:EventBus
Attempts to register the subscriber to the specified Classifier
-
unsubscribe
public boolean unsubscribe(ActorRef subscriber, ActorRef from)
Description copied from interface:EventBus
Attempts to deregister the subscriber from the specified Classifier- Specified by:
unsubscribe
in interfaceEventBus<E,ActorRef,ActorRef>
- Returns:
- true if successful and false if not (because it wasn't subscribed to that Classifier, or otherwise)
-
-