akka.typed.internal

Class EventStreamImpl

java.lang.Object

akka.typed.internal.EventStreamImpl

All Implemented Interfaces:

EventStream

public class EventStreamImpl
extends java.lang.Object
implements EventStream

INTERNAL API

An Akka 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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	EventStreamImpl.Command
static class	EventStreamImpl.Register
static class	EventStreamImpl.Register$
class	EventStreamImpl.SerializedStandardOutLogger
class	EventStreamImpl.StandardOutLogger Actor-less logging implementation for synchronous logging to standard output.
static class	EventStreamImpl.UnregisterIfNoMoreSubscribedChannels
static class	EventStreamImpl.UnregisterIfNoMoreSubscribedChannels$

Constructor Summary

Constructors

Constructor and Description
EventStreamImpl(boolean debug, Timeout timeout)

Method Summary

Modifier and Type	Method and Description
Logging.LogLevel	logLevel() Query currently set log level.
<T> void	publish(T event) Publishes the specified Event to this bus
void	setLogLevel(Logging.LogLevel level) Change log level: default loggers (i.e.
static RootActorPath	StandardOutLoggerPath()
void	startDefaultLoggers(ActorSystemImpl<scala.runtime.Nothing$> system)
void	startStdoutLogger(Settings settings)
void	startUnsubscriber(ActorSystem<scala.runtime.Nothing$> sys) ''Must'' be called after actor system is "ready".
void	stopDefaultLoggers(ActorSystem<scala.runtime.Nothing$> system)
<T> boolean	subscribe(ActorRef<T> subscriber, java.lang.Class<T> channel) Attempts to register the subscriber to the specified Classifier
<T> void	unsubscribe(ActorRef<T> subscriber) Attempts to deregister the subscriber from all Classifiers it may be subscribed to
<T> boolean	unsubscribe(ActorRef<T> subscriber, java.lang.Class<T> channel) 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 Detail

EventStreamImpl

public EventStreamImpl(boolean debug,
                       Timeout timeout)

Method Detail

StandardOutLoggerPath

public static RootActorPath StandardOutLoggerPath()

startUnsubscriber

public void startUnsubscriber(ActorSystem<scala.runtime.Nothing$> sys)

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

Parameters:

sys - (undocumented)

logLevel

public Logging.LogLevel logLevel()

Query currently set log level. See object Logging for more information.

Specified by:

logLevel in interface EventStream

Returns:

(undocumented)

setLogLevel

public void setLogLevel(Logging.LogLevel level)

Change log level: default loggers (i.e. from configuration file) are subscribed/unsubscribed as necessary so that they listen to all levels which are at least as severe as the given one. See object Logging for more information.

NOTE: if the StandardOutLogger is configured also as normal logger, it will not participate in the automatic management of log level subscriptions!

Specified by:

setLogLevel in interface EventStream

Parameters:

level - (undocumented)

startStdoutLogger

public void startStdoutLogger(Settings settings)

startDefaultLoggers

public void startDefaultLoggers(ActorSystemImpl<scala.runtime.Nothing$> system)

stopDefaultLoggers

public void stopDefaultLoggers(ActorSystem<scala.runtime.Nothing$> system)

subscribe

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

Description copied from interface: EventStream

Attempts to register the subscriber to the specified Classifier

Specified by:

subscribe in interface EventStream

Parameters:

subscriber - (undocumented)

channel - (undocumented)

Returns:

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

unsubscribe

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

Description copied from interface: EventStream

Attempts to deregister the subscriber from the specified Classifier

Specified by:

unsubscribe in interface EventStream

Parameters:

subscriber - (undocumented)

channel - (undocumented)

Returns:

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

unsubscribe

public <T> void unsubscribe(ActorRef<T> subscriber)

Description copied from interface: EventStream

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

Specified by:

unsubscribe in interface EventStream

Parameters:

subscriber - (undocumented)

publish

public <T> void publish(T event)

Description copied from interface: EventStream

Publishes the specified Event to this bus

Specified by:

publish in interface EventStream

Parameters:

event - (undocumented)