public class EventStream extends java.lang.Object implements LoggingBus, SubchannelClassification
Constructor and Description |
---|
EventStream(ActorSystem sys) |
EventStream(ActorSystem sys,
boolean debug) |
EventStream(boolean debug) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Class<?> |
classify(java.lang.Object event) |
static EventStream |
fromActorSystem(ActorSystem system) |
boolean |
initUnsubscriber(ActorRef unsubscriber)
INTERNAL API
|
protected void |
publish(java.lang.Object event,
ActorRef subscriber) |
void |
startUnsubscriber()
''Must'' be called after actor system is "ready".
|
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
_logLevel, addLogger, guard, loggers, logLevel, setLogLevel, setUpStdoutLogger, startDefaultLoggers, startStdoutLogger, stopDefaultLoggers
compareSubscribers
publish, subscribe, unsubscribe, unsubscribe
addToCache, cache, classify, hasSubscriptions, publish, publish, removeFromCache, subscribe, subscriptions, unsubscribe, unsubscribe
public EventStream(ActorSystem sys, boolean debug)
public EventStream(ActorSystem sys)
public EventStream(boolean debug)
public static EventStream fromActorSystem(ActorSystem system)
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)