public class EventStream extends java.lang.Object implements LoggingBus, SubchannelClassification
Constructor and Description |
---|
EventStream(boolean debug) |
Modifier and Type | Method and Description |
---|---|
protected java.lang.Class<?> |
classify(java.lang.Object event)
Returns the Classifier associated with the given Event
|
static EventStream |
fromActorSystem(ActorSystem system) |
protected void |
publish(java.lang.Object event,
ActorRef subscriber)
Publishes the given Event to the given Subscriber
|
protected java.lang.Object |
subclassification()
The logic to form sub-class hierarchy
|
boolean |
subscribe(ActorRef subscriber,
java.lang.Class<?> channel) |
void |
unsubscribe(ActorRef subscriber)
Attempts to deregister the subscriber from all Classifiers it may be subscribed to
|
boolean |
unsubscribe(ActorRef subscriber,
java.lang.Class<?> channel)
Attempts to deregister the subscriber from the specified Classifier
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
_logLevel, addLogger, guard, loggers, logLevel, setLogLevel, setUpStdoutLogger, startDefaultLoggers, startStdoutLogger, stopDefaultLoggers
compareSubscribers
addToCache, cache, publish, removeFromCache, subscriptions
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)
SubchannelClassification
classify
in interface SubchannelClassification
protected void publish(java.lang.Object event, ActorRef subscriber)
SubchannelClassification
publish
in interface SubchannelClassification
public boolean subscribe(ActorRef subscriber, java.lang.Class<?> channel)
subscribe
in interface EventBus
subscribe
in interface SubchannelClassification
public boolean unsubscribe(ActorRef subscriber, java.lang.Class<?> channel)
EventBus
unsubscribe
in interface EventBus
unsubscribe
in interface SubchannelClassification
public void unsubscribe(ActorRef subscriber)
EventBus
unsubscribe
in interface EventBus
unsubscribe
in interface SubchannelClassification