ManagedActorEventBus

org.apache.pekko.event.japi.ManagedActorEventBus
abstract class ManagedActorEventBus[E](system: ActorSystem) extends 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

Attributes

Source
EventBusJavaAPI.scala
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

protected def classify(event: E): ActorRef

Returns the Classifier associated with the given Event

Returns the Classifier associated with the given Event

Attributes

Source
EventBusJavaAPI.scala
protected def mapSize(): Int

This is a size hint for the number of Classifiers you expect to have (use powers of 2)

This is a size hint for the number of Classifiers you expect to have (use powers of 2)

Attributes

Source
EventBusJavaAPI.scala

Concrete methods

override def publish(event: E): Unit

Publishes the specified Event to this bus

Publishes the specified Event to this bus

Attributes

Definition Classes
Source
EventBusJavaAPI.scala
override def subscribe(subscriber: ActorRef, to: ActorRef): Boolean

Attempts to register the subscriber to the specified Classifier

Attempts to register the subscriber to the specified Classifier

Attributes

Returns

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

Definition Classes
Source
EventBusJavaAPI.scala
override def unsubscribe(subscriber: ActorRef, from: ActorRef): Boolean

Attempts to deregister the subscriber from the specified Classifier

Attempts to deregister the subscriber from the specified Classifier

Attributes

Returns

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

Definition Classes
Source
EventBusJavaAPI.scala
override def unsubscribe(subscriber: ActorRef): Unit

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

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

Attributes

Definition Classes
Source
EventBusJavaAPI.scala