Package org.apache.pekko.event.japi

Class ManagedActorEventBus<E>

java.lang.Object

org.apache.pekko.event.japi.ManagedActorEventBus<E>

All Implemented Interfaces:

EventBus<E,ActorRef,ActorRef>

public abstract class ManagedActorEventBus<E>
extends Object
implements EventBus<E,ActorRef,ActorRef>

Java API: See documentation for pekko.event.ManagedActorClassification 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

Modifier and Type	Method	Description
protected abstract ActorRef	classify(E event)	Returns the Classifier associated with the given Event
protected 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 bus
boolean	subscribe(ActorRef subscriber, ActorRef to)	Attempts to register the subscriber to the specified Classifier
void	unsubscribe(ActorRef subscriber)	Attempts to deregister the subscriber from all Classifiers it may be subscribed to
boolean	unsubscribe(ActorRef subscriber, ActorRef from)	Attempts to deregister the subscriber from the specified Classifier

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ManagedActorEventBus

public ManagedActorEventBus(ActorSystem system)

Method Details

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

Specified by:

publish in interface EventBus<E,ActorRef,ActorRef>

subscribe

public boolean subscribe(ActorRef subscriber,
 ActorRef to)

Description copied from interface: EventBus

Attempts to register the subscriber to the specified Classifier

Specified by:

subscribe in interface EventBus<E,ActorRef,ActorRef>

Returns:

true if successful and false if not (because it was already subscribed to that Classifier, or otherwise)

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 interface EventBus<E,ActorRef,ActorRef>

Returns:

true if successful and false if not (because it wasn't subscribed to that Classifier, or otherwise)

unsubscribe

public void unsubscribe(ActorRef subscriber)

Description copied from interface: EventBus

Attempts to deregister the subscriber from all Classifiers it may be subscribed to

Specified by:

unsubscribe in interface EventBus<E,ActorRef,ActorRef>