Package 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

Either the list of subscribed actors, or a ref to an EventStreamUnsubscriber

Constructor Summary

Constructors

Constructor	Description
EventStream(ActorSystem sys)
EventStream(ActorSystem sys, boolean debug)

Method Summary

Modifier and Type	Method	Description
protected java.lang.Class<?>	classify(java.lang.Object event)
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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.LoggingBus

_logLevel_$eq, addLogger, loggers_$eq, logLevel, setLogLevel, setUpStdoutLogger, startDefaultLoggers, startStdoutLogger, stopDefaultLoggers

Methods inherited from interface akka.event.SubchannelClassification

addToCache, cache_$eq, classify, hasSubscriptions, publish, publish, removeFromCache, subscribe, unsubscribe, unsubscribe

Constructor Detail

EventStream

public EventStream(ActorSystem sys,
                   boolean debug)

EventStream

public EventStream(ActorSystem sys)

Method Detail

classify

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

initUnsubscriber

public final boolean initUnsubscriber(ActorRef unsubscriber)

INTERNAL API

Parameters:

unsubscriber - (undocumented)

Returns:

(undocumented)

publish

protected void publish(java.lang.Object event,
                       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.

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)

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)