Package org.axonframework.messaging.eventstreaming
@NullMarked
package org.axonframework.messaging.eventstreaming
Part of the Axon Messaging module. Contains classes related to eventstreaming.
-
ClassDescriptionDescribes the criteria for
EventStoreTransaction#source(SourcingCondition) sourcingorevents.invalid reference
streamingDescribes a singular, non-nested criteria for filtering events.Interface describing a condition that the type and tags of event messages must match against in order to be relevant.AnEventCriteriathat can be restricted to a specific set of event types.ATrackingTokenimplementation combining severalTrackingTokensinto one.AStreamableEventSourceimplementation that allows streaming event processors to process events from multiple underlying event sources.Intermediate builder for collecting event sources before creating a MultiStreamableEventSource.Builder class to construct anEventCriteriathat will match the to-be-built criteria and the already existing criteria.Interface towards a streamable event source.Interface describing the condition tofrom a streamable event source (like an Event Store).invalid reference
streamAnTagrefers to fields and their values within which anEventMessagehas been published, typically referring to domain-specifics used for identification.Provides functionality to retrieveTrackingTokensfor the head and tail of the stream, and at a given point in time in the stream.