Package org.apache.pekko.event

Class EventStream

java.lang.Object

org.apache.pekko.event.EventStream

All Implemented Interfaces:

ActorEventBus, EventBus, LoggingBus, SubchannelClassification

public class EventStream
extends java.lang.Object
implements LoggingBus, SubchannelClassification

An Apache Pekko EventStream is a pub-sub stream of events both system and user generated, where subscribers are ActorRefs and the channels are Classes and Events are any java.lang.Object. EventStreams employ SubchannelClassification, which means that if you listen to a Class, you'll receive any message that is of that type or a subtype.

The debug flag in the constructor toggles if operations on this EventStream should also be published as Debug-Events

Constructor Summary

Constructors

Constructor	Description
EventStream(ActorSystem sys)
EventStream(ActorSystem sys, boolean debug)

Method Summary

Modifier and Type	Method	Description
protected java.lang.Class<?>	classify(java.lang.Object event)
protected void	publish(java.lang.Object event, ActorRef subscriber)
void	startUnsubscriber()	''Must'' be called after actor system is "ready".
protected Subclassification<java.lang.Class<?>>	subclassification()	The logic to form sub-class hierarchy
boolean	subscribe(ActorRef subscriber, java.lang.Class<?> channel)
void	unsubscribe(ActorRef subscriber)
boolean	unsubscribe(ActorRef subscriber, java.lang.Class<?> channel)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.event.ActorEventBus

compareSubscribers

Methods inherited from interface org.apache.pekko.event.EventBus

publish, subscribe, unsubscribe, unsubscribe

Methods inherited from interface org.apache.pekko.event.LoggingBus

_logLevel_$eq, addLogger, loggers_$eq, logLevel, setLogLevel, setUpStdoutLogger, startDefaultLoggers, startStdoutLogger, stopDefaultLoggers

Methods inherited from interface org.apache.pekko.event.SubchannelClassification

addToCache, cache_$eq, classify, hasSubscriptions, publish, publish, removeFromCache, subscribe, unsubscribe, unsubscribe

Constructor Detail

EventStream

public EventStream(ActorSystem sys,
                   boolean debug)

EventStream

public EventStream(ActorSystem sys)

Method Detail

classify

protected java.lang.Class<?> classify(java.lang.Object event)

publish

protected void publish(java.lang.Object event,
                       ActorRef subscriber)

startUnsubscriber

public void startUnsubscriber()

''Must'' be called after actor system is "ready". Starts system actor that takes care of unsubscribing subscribers that have terminated.

subclassification

protected Subclassification<java.lang.Class<?>> subclassification()

Description copied from interface: SubchannelClassification

The logic to form sub-class hierarchy

Specified by:

subclassification in interface SubchannelClassification

subscribe

public boolean subscribe(ActorRef subscriber,
                         java.lang.Class<?> channel)

unsubscribe

public boolean unsubscribe(ActorRef subscriber,
                           java.lang.Class<?> channel)

unsubscribe

public void unsubscribe(ActorRef subscriber)