akka.typed

Interface EventStream

All Known Implementing Classes:

EventStreamAdapter, EventStreamImpl

public interface EventStream

An EventStream allows local actors to register for certain message types, including their subtypes automatically. Publishing events will broadcast them to all currently subscribed actors with matching subscriptions for the event type.

IMPORTANT NOTICE

This EventStream is local to the ActorSystem, it does not span a cluster. For disseminating messages across a cluster please refer to the DistributedPubSub module.

Method Summary

Modifier and Type	Method and Description
Logging.LogLevel	logLevel() Query the current minimum log level.
<T> void	publish(T event) Publishes the specified Event to this bus
void	setLogLevel(Logging.LogLevel loglevel) Change the current minimum log level.
<T> boolean	subscribe(ActorRef<T> subscriber, java.lang.Class<T> to) 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> from) Attempts to deregister the subscriber from the specified Classifier

Method Detail

subscribe

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

Attempts to register the subscriber to the specified Classifier

Parameters:

subscriber - (undocumented)

to - (undocumented)

Returns:

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

unsubscribe

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

Attempts to deregister the subscriber from the specified Classifier

Parameters:

subscriber - (undocumented)

from - (undocumented)

Returns:

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

unsubscribe

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

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

Parameters:

subscriber - (undocumented)

publish

<T> void publish(T event)

Publishes the specified Event to this bus

Parameters:

event - (undocumented)

logLevel

Logging.LogLevel logLevel()

Query the current minimum log level.

Returns:

(undocumented)

setLogLevel

void setLogLevel(Logging.LogLevel loglevel)

Change the current minimum log level.

Parameters:

loglevel - (undocumented)