Package org.apache.pekko.event

Interface ScanningClassification

public interface ScanningClassification

Maps Classifiers to Subscribers and selects which Subscriber should receive which publication through scanning through all Subscribers through the matches(classifier, event) method

Note: the compareClassifiers and compareSubscribers must together form an absolute ordering (think java.util.Comparator.compare)

Method Summary

Modifier and Type	Method	Description
int	compareClassifiers(ScanningClassification a, ScanningClassification b)	Provides a total ordering of Classifiers (think java.util.Comparator.compare)
int	compareSubscribers(ScanningClassification a, ScanningClassification b)	Provides a total ordering of Subscribers (think java.util.Comparator.compare)
boolean	matches(ScanningClassification classifier, ScanningClassification event)	Returns whether the specified Classifier matches the specified Event
void	org$apache$pekko$event$ScanningClassification$_setter_$subscribers_$eq(java.util.concurrent.ConcurrentSkipListSet<scala.Tuple2<java.lang.Object,java.lang.Object>> x$1)
void	publish(ScanningClassification event)
void	publish(ScanningClassification event, ScanningClassification subscriber)	Publishes the specified Event to the specified Subscriber
boolean	subscribe(ScanningClassification subscriber, ScanningClassification to)
java.util.concurrent.ConcurrentSkipListSet<scala.Tuple2<java.lang.Object,java.lang.Object>>	subscribers()
void	unsubscribe(ScanningClassification subscriber)
boolean	unsubscribe(ScanningClassification subscriber, ScanningClassification from)

Method Detail

compareClassifiers

int compareClassifiers(ScanningClassification a,
                       ScanningClassification b)

Provides a total ordering of Classifiers (think java.util.Comparator.compare)

compareSubscribers

int compareSubscribers(ScanningClassification a,
                       ScanningClassification b)

Provides a total ordering of Subscribers (think java.util.Comparator.compare)

matches

boolean matches(ScanningClassification classifier,
                ScanningClassification event)

Returns whether the specified Classifier matches the specified Event

org$apache$pekko$event$ScanningClassification$_setter_$subscribers_$eq

void org$apache$pekko$event$ScanningClassification$_setter_$subscribers_$eq(java.util.concurrent.ConcurrentSkipListSet<scala.Tuple2<java.lang.Object,java.lang.Object>> x$1)

publish

void publish(ScanningClassification event,
             ScanningClassification subscriber)

Publishes the specified Event to the specified Subscriber

publish

void publish(ScanningClassification event)

subscribe

boolean subscribe(ScanningClassification subscriber,
                  ScanningClassification to)

subscribers

java.util.concurrent.ConcurrentSkipListSet<scala.Tuple2<java.lang.Object,java.lang.Object>> subscribers()

unsubscribe

boolean unsubscribe(ScanningClassification subscriber,
                    ScanningClassification from)

unsubscribe

void unsubscribe(ScanningClassification subscriber)