akka.event

Interface SubchannelClassification

All Known Implementing Classes:

EventStream

public interface SubchannelClassification

Classification which respects relationships between channels: subscribing to one channel automatically and idempotently subscribes to all sub-channels.

Method Summary

Modifier and Type	Method and Description
void	addToCache(scala.collection.immutable.Seq<scala.Tuple2<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>>> changes)
SubchannelClassification	classify(SubchannelClassification event) Returns the Classifier associated with the given Event
boolean	hasSubscriptions(SubchannelClassification subscriber) INTERNAL API Expensive call! Avoid calling directly from event bus subscribe / unsubscribe.
void	publish(SubchannelClassification event)
void	publish(SubchannelClassification event, SubchannelClassification subscriber) Publishes the given Event to the given Subscriber
void	removeFromCache(scala.collection.immutable.Seq<scala.Tuple2<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>>> changes)
Subclassification<java.lang.Object>	subclassification() The logic to form sub-class hierarchy
boolean	subscribe(SubchannelClassification subscriber, SubchannelClassification to)
void	unsubscribe(SubchannelClassification subscriber)
boolean	unsubscribe(SubchannelClassification subscriber, SubchannelClassification from)

Method Detail

subclassification

Subclassification<java.lang.Object> subclassification()

The logic to form sub-class hierarchy

Returns:

(undocumented)

classify

SubchannelClassification classify(SubchannelClassification event)

Returns the Classifier associated with the given Event

Parameters:

event - (undocumented)

Returns:

(undocumented)

publish

void publish(SubchannelClassification event,
             SubchannelClassification subscriber)

Publishes the given Event to the given Subscriber

Parameters:

event - (undocumented)

subscriber - (undocumented)

subscribe

boolean subscribe(SubchannelClassification subscriber,
                  SubchannelClassification to)

unsubscribe

boolean unsubscribe(SubchannelClassification subscriber,
                    SubchannelClassification from)

unsubscribe

void unsubscribe(SubchannelClassification subscriber)

publish

void publish(SubchannelClassification event)

hasSubscriptions

boolean hasSubscriptions(SubchannelClassification subscriber)

INTERNAL API Expensive call! Avoid calling directly from event bus subscribe / unsubscribe.

Parameters:

subscriber - (undocumented)

Returns:

(undocumented)

removeFromCache

void removeFromCache(scala.collection.immutable.Seq<scala.Tuple2<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>>> changes)

addToCache

void addToCache(scala.collection.immutable.Seq<scala.Tuple2<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>>> changes)