akka.event

Class EventStream

java.lang.Object

akka.event.EventStream

All Implemented Interfaces:

ActorEventBus, EventBus, LoggingBus, SubchannelClassification

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

Constructor Summary

Constructors

Constructor and Description
EventStream(ActorSystem sys)
EventStream(ActorSystem sys, boolean debug)
EventStream(boolean debug) Deprecated. Use constructor with ActorSystem parameter. Since 2.4.

Method Summary

Modifier and Type	Method and Description
protected abstract static void	akka$event$LoggingBus$_setter_$akka$event$LoggingBus$$guard_$eq(ReentrantGuard x$1)
static void	akka$event$LoggingBus$$_logLevel_$eq(Logging.LogLevel x$1)
static Logging.LogLevel	akka$event$LoggingBus$$_logLevel()
static ReentrantGuard	akka$event$LoggingBus$$guard()
static void	akka$event$LoggingBus$$loggers_$eq(scala.collection.Seq<ActorRef> x$1)
static scala.collection.Seq<ActorRef>	akka$event$LoggingBus$$loggers()
static void	akka$event$SubchannelClassification$$cache_$eq(scala.collection.immutable.Map<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>> x$1)
static scala.collection.immutable.Map<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>>	akka$event$SubchannelClassification$$cache()
static SubclassifiedIndex<java.lang.Object,java.lang.Object>	akka$event$SubchannelClassification$$subscriptions()
protected java.lang.Class<?>	classify(java.lang.Object event)
protected static int	compareSubscribers(ActorRef a, ActorRef b)
static EventStream	fromActorSystem(ActorSystem system) Deprecated. Use explicit `system.eventStream` instead. Since 2.4.
static boolean	hasSubscriptions(SubchannelClassification subscriber)
boolean	initUnsubscriber(ActorRef unsubscriber) INTERNAL API
static Logging.LogLevel	logLevel()
protected void	publish(java.lang.Object event, ActorRef subscriber)
static void	setLogLevel(Logging.LogLevel level)
static void	startDefaultLoggers(ActorSystemImpl system)
static void	startStdoutLogger(ActorSystem.Settings config)
void	startUnsubscriber() ''Must'' be called after actor system is "ready".
static void	stopDefaultLoggers(ActorSystem system)
protected java.lang.Object	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 akka.event.LoggingBus

addLogger, logLevel, setLogLevel, setUpStdoutLogger, startDefaultLoggers, startStdoutLogger, stopDefaultLoggers

Methods inherited from interface akka.event.ActorEventBus

compareSubscribers

Methods inherited from interface akka.event.EventBus

publish, subscribe, unsubscribe, unsubscribe

Methods inherited from interface akka.event.SubchannelClassification

addToCache, classify, hasSubscriptions, publish, publish, removeFromCache, subscribe, unsubscribe, unsubscribe

Constructor Detail

EventStream

public EventStream(ActorSystem sys,
                   boolean debug)

EventStream

public EventStream(ActorSystem sys)

EventStream

public EventStream(boolean debug)

Deprecated. Use constructor with ActorSystem parameter. Since 2.4.

Method Detail

fromActorSystem

public static EventStream fromActorSystem(ActorSystem system)

Deprecated. Use explicit `system.eventStream` instead. Since 2.4.

compareSubscribers

protected static int compareSubscribers(ActorRef a,
                                        ActorRef b)

akka$event$LoggingBus$$guard

public static ReentrantGuard akka$event$LoggingBus$$guard()

akka$event$LoggingBus$$loggers

public static scala.collection.Seq<ActorRef> akka$event$LoggingBus$$loggers()

akka$event$LoggingBus$$loggers_$eq

public static void akka$event$LoggingBus$$loggers_$eq(scala.collection.Seq<ActorRef> x$1)

akka$event$LoggingBus$$_logLevel

public static Logging.LogLevel akka$event$LoggingBus$$_logLevel()

akka$event$LoggingBus$$_logLevel_$eq

public static void akka$event$LoggingBus$$_logLevel_$eq(Logging.LogLevel x$1)

logLevel

public static Logging.LogLevel logLevel()

setLogLevel

public static void setLogLevel(Logging.LogLevel level)

startStdoutLogger

public static void startStdoutLogger(ActorSystem.Settings config)

startDefaultLoggers

public static void startDefaultLoggers(ActorSystemImpl system)

stopDefaultLoggers

public static void stopDefaultLoggers(ActorSystem system)

akka$event$LoggingBus$_setter_$akka$event$LoggingBus$$guard_$eq

protected abstract static void akka$event$LoggingBus$_setter_$akka$event$LoggingBus$$guard_$eq(ReentrantGuard x$1)

akka$event$SubchannelClassification$$subscriptions

public static SubclassifiedIndex<java.lang.Object,java.lang.Object> akka$event$SubchannelClassification$$subscriptions()

akka$event$SubchannelClassification$$cache

public static scala.collection.immutable.Map<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>> akka$event$SubchannelClassification$$cache()

akka$event$SubchannelClassification$$cache_$eq

public static void akka$event$SubchannelClassification$$cache_$eq(scala.collection.immutable.Map<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>> x$1)

hasSubscriptions

public static boolean hasSubscriptions(SubchannelClassification subscriber)

subclassification

protected java.lang.Object subclassification()

Description copied from interface: SubchannelClassification

The logic to form sub-class hierarchy

Specified by:

subclassification in interface SubchannelClassification

Returns:

(undocumented)

classify

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

publish

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

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)

startUnsubscriber

public void startUnsubscriber()

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

initUnsubscriber

public final boolean initUnsubscriber(ActorRef unsubscriber)

INTERNAL API

Parameters:

unsubscriber - (undocumented)

Returns:

(undocumented)