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


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


publish

void publish(SubchannelClassification event,
             SubchannelClassification subscriber)
Publishes the given Event to the given Subscriber


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)