akka.event
Interface SubchannelClassification

All Known Implementing Classes:
EventStream, SubchannelEventBus

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()
           
 akka.event.EventBus.Classifier classify(akka.event.EventBus.Event event)
          Returns the Classifier associated with the given Event
 void publish(akka.event.EventBus.Event event)
           
 void publish(akka.event.EventBus.Event event, akka.event.EventBus.Subscriber 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()
           
 boolean subscribe(akka.event.EventBus.Subscriber subscriber, akka.event.EventBus.Classifier to)
           
  subscriptions()
           
 void unsubscribe(akka.event.EventBus.Subscriber subscriber)
           
 boolean unsubscribe(akka.event.EventBus.Subscriber subscriber, akka.event.EventBus.Classifier from)
           
 

Method Detail

subclassification

Subclassification<java.lang.Object> subclassification()

subscriptions

 subscriptions()

cache

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

classify

akka.event.EventBus.Classifier classify(akka.event.EventBus.Event event)
Returns the Classifier associated with the given Event


publish

void publish(akka.event.EventBus.Event event,
             akka.event.EventBus.Subscriber subscriber)
Publishes the given Event to the given Subscriber


subscribe

boolean subscribe(akka.event.EventBus.Subscriber subscriber,
                  akka.event.EventBus.Classifier to)

unsubscribe

boolean unsubscribe(akka.event.EventBus.Subscriber subscriber,
                    akka.event.EventBus.Classifier from)

unsubscribe

void unsubscribe(akka.event.EventBus.Subscriber subscriber)

publish

void publish(akka.event.EventBus.Event 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)