akka.typed.adapter

Class EventStreamAdapter

java.lang.Object

akka.typed.adapter.EventStreamAdapter

All Implemented Interfaces:

EventStream

public class EventStreamAdapter
extends java.lang.Object
implements EventStream

Constructor Summary

Constructors

Constructor and Description
EventStreamAdapter(EventStream untyped)

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

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamAdapter

public EventStreamAdapter(EventStream untyped)

Method Detail

logLevel

public Logging.LogLevel logLevel()

Description copied from interface: EventStream

Query the current minimum log level.

Specified by:

logLevel in interface EventStream

Returns:

(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)

setLogLevel

public void setLogLevel(Logging.LogLevel loglevel)

Description copied from interface: EventStream

Change the current minimum log level.

Specified by:

setLogLevel in interface EventStream

Parameters:

loglevel - (undocumented)

subscribe

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

Description copied from interface: EventStream

Attempts to register the subscriber to the specified Classifier

Specified by:

subscribe in interface EventStream

Parameters:

subscriber - (undocumented)

to - (undocumented)

Returns:

true if successful and false if not (because it was already 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)

unsubscribe

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

Description copied from interface: EventStream

Attempts to deregister the subscriber from the specified Classifier

Specified by:

unsubscribe in interface EventStream

Parameters:

subscriber - (undocumented)

from - (undocumented)

Returns:

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