Package org.apache.pekko.event
package org.apache.pekko.event
-
ClassDescriptionINTERNAL APICan be mixed into an EventBus to specify that the Classifier type is ActorRefRepresents an EventBus where the Subscriber type is ActorRefINTERNAL API
pekko.event.LoggingAdapterthat publishespekko.event.Logging.LogEventto event stream.Represents the base type for EventBuses Internally has an Event type, a Classifier type and a Subscriber typeAn Apache Pekko EventStream is a pub-sub stream of events both system and user generated, where subscribers are ActorRefs and the channels are Classes and Events are any java.lang.Object.INTERNAL APIArtificial exception injected into Error events if no Throwable is supplied; used for getting a stack dump of error locations.This trait brings log level handling to the EventStream: it reads the log levels for the initial logging (StandardOutLogger) and the loggers & level for after-init logging, possibly keeping the StandardOutLogger enabled if it is part of the configured loggers.This decorator adds invocation logging to a Receive function.DO NOT INHERIT: Class is open only for use by pekko-slf4jINTERNAL APILogSource<T>Maps Subscribers to Classifiers using equality on Classifier to store a Set of Subscribers (hence the need for compareSubscribers) Maps Events to Classifiers through the classify-method (so it knows who to publish to)Maps ActorRefs to ActorRefs to form an EventBus where ActorRefs can listen to other ActorRefs.LoggingAdapterextension which adds Marker support.NoLogging is a LoggingAdapter that does absolutely nothing – no logging at all.NoLogging is a LoggingAdapter that does absolutely nothing – no logging at all.NoLogging is a MarkerLoggingAdapter that does absolutely nothing – no logging at all.NoLogging is a MarkerLoggingAdapter that does absolutely nothing – no logging at all.Can be mixed into an EventBus to specify that the Classifier type is a Function from Event to Boolean (predicate)Maps Classifiers to Subscribers and selects which Subscriber should receive which publication through scanning through all Subscribers through the matches(classifier, event) methodClassification which respects relationships between channels: subscribing to one channel automatically and idempotently subscribes to all sub-channels.