Maps ActorRefs to ActorRefs to form an EventBus where ActorRefs can listen to other ActorRefs
Can be mixed into an EventBus to specify that the Classifier type is ActorRef
Represents an EventBus where the Subscriber type is ActorRef
The contract of DeathWatch is not properly expressed using the type system Whenever there is a publish, all listeners to the Terminated Actor should be atomically removed A failed subscribe should also only mean that the Classifier (ActorRef) that is listened to is already shut down See LocalDeathWatch for semantics
This is a “marker” class which is inserted as originator class into akka.event.LogEvent when the string representation was supplied directly.
Represents the base type for EventBuses Internally has an Event type, a Classifier type and a Subscriber type
An Akka 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.
This trait defines the interface to be provided by a “log source formatting
rule” as used by akka.event.Logging’s
Logging wrapper to make nicer and optimize: provide template versions which evaluate .
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.
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)
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) method
Classification which respects relationships between channels: subscribing to one channel automatically and idempotently subscribes to all sub-channels.
This object holds predefined formatting rules for log sources.
Main entry point for Akka logging: log levels and message types (aka channels) defined for the main transport medium, the main event bus.
Migration replacement for