akka.event
Class EventStream

java.lang.Object
  extended by akka.event.EventStream
All Implemented Interfaces:
ActorEventBus, EventBus, LoggingBus, SubchannelClassification

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


Constructor Summary
EventStream(boolean debug)
           
 
Method Summary
protected  java.lang.Class<?> classify(java.lang.Object event)
           
static EventStream fromActorSystem(ActorSystem system)
           
protected  void publish(java.lang.Object event, ActorRef 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)
           
 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
_logLevel, addLogger, guard, loggers, 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, cache, classify, publish, publish, removeFromCache, subscribe, subscriptions, unsubscribe, unsubscribe
 

Constructor Detail

EventStream

public EventStream(boolean debug)
Method Detail

fromActorSystem

public static EventStream fromActorSystem(ActorSystem system)

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)