public class EventStream extends java.lang.Object implements LoggingBus, SubchannelClassification
Constructor and Description |
---|
EventStream(ActorSystem sys) |
EventStream(ActorSystem sys,
boolean debug) |
EventStream(boolean debug)
Deprecated.
Use constructor with ActorSystem parameter. Since 2.4.
|
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addLogger, logLevel, setLogLevel, setUpStdoutLogger, startDefaultLoggers, startStdoutLogger, stopDefaultLoggers
compareSubscribers
publish, subscribe, unsubscribe, unsubscribe
addToCache, classify, hasSubscriptions, publish, publish, removeFromCache, subscribe, unsubscribe, unsubscribe
public EventStream(ActorSystem sys, boolean debug)
public EventStream(ActorSystem sys)
public EventStream(boolean debug)
public static EventStream fromActorSystem(ActorSystem system)
public static ReentrantGuard akka$event$LoggingBus$$guard()
public static scala.collection.Seq<ActorRef> akka$event$LoggingBus$$loggers()
public static void akka$event$LoggingBus$$loggers_$eq(scala.collection.Seq<ActorRef> x$1)
public static Logging.LogLevel akka$event$LoggingBus$$_logLevel()
public static void akka$event$LoggingBus$$_logLevel_$eq(Logging.LogLevel x$1)
public static Logging.LogLevel logLevel()
public static void setLogLevel(Logging.LogLevel level)
public static void startStdoutLogger(ActorSystem.Settings config)
public static void startDefaultLoggers(ActorSystemImpl system)
public static void stopDefaultLoggers(ActorSystem system)
protected abstract static void akka$event$LoggingBus$_setter_$akka$event$LoggingBus$$guard_$eq(ReentrantGuard x$1)
public static SubclassifiedIndex<java.lang.Object,java.lang.Object> akka$event$SubchannelClassification$$subscriptions()
public static scala.collection.immutable.Map<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>> akka$event$SubchannelClassification$$cache()
public static void akka$event$SubchannelClassification$$cache_$eq(scala.collection.immutable.Map<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>> x$1)
public static boolean hasSubscriptions(SubchannelClassification subscriber)
protected java.lang.Object subclassification()
SubchannelClassification
subclassification
in interface SubchannelClassification
protected java.lang.Class<?> classify(java.lang.Object event)
protected void publish(java.lang.Object event, ActorRef subscriber)
public boolean subscribe(ActorRef subscriber, java.lang.Class<?> channel)
public boolean unsubscribe(ActorRef subscriber, java.lang.Class<?> channel)
public void unsubscribe(ActorRef subscriber)
public void startUnsubscriber()
public final boolean initUnsubscriber(ActorRef unsubscriber)
unsubscriber
- (undocumented)