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
 void addToCache(scala.collection.immutable.Seq<scala.Tuple2<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>>> changes)
           
 scala.collection.immutable.Map<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>> cache()
           
 SubchannelClassification classify(SubchannelClassification event)
          Returns the Classifier associated with the given Event
 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)
           
 SubclassifiedIndex<java.lang.Object,java.lang.Object> subscriptions()
           
 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)

subscriptions

SubclassifiedIndex<java.lang.Object,java.lang.Object> subscriptions()

cache

scala.collection.immutable.Map<java.lang.Object,scala.collection.immutable.Set<java.lang.Object>> cache()

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)

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)