Package io.axoniq.framework.axonserver.connector.event

@NullMarked package io.axoniq.framework.axonserver.connector.event

Part of the Axon Server Connector module. Contains classes related to event.

Class	Description
AggregateBasedAxonServerEventStorageEngine	Event Storage Engine implementation that uses the aggregate-oriented APIs of Axon Server, allowing it to interact with versions that do not have DCB support.
AxonServerEventStorageEngine	An EventStorageEngine implementation using Axon Server through the axonserver-connector-java project.
AxonServerEventStorageEngineFactory	A ComponentFactory implementation that generates AxonServerEventStorageEngine instances.
ConditionConverter	Utility class containing operations to convert Axon Framework's SourcingCondition and StreamingCondition into an Axon Server SourceEventsRequest and StreamEventsRequest respectively.
DefaultPersistentStreamEventSourceFactory	Default implementation of PersistentStreamEventSourceFactory.
EventProcessorControlService	Service that listens to PlatformOutboundInstructions to control EventProcessors when requested by Axon Server.
EventProcessorControlService.AxonProcessorInstructionHandler
PersistentStreamConnection	A connection instance receiving the events for a persistent stream to pass on in batches to an event consumer.
PersistentStreamEventSource	A SubscribableEventSource that receives events from a persistent stream on Axon Server.
PersistentStreamEventSourceFactory	Factory for creating PersistentStreamEventSource instances.
PersistentStreamScheduledExecutorBuilder	Functional interface towards constructing a ScheduledExecutorService for a PersistentStreamEventSource.
PersistentStreamSequencingPolicy	Interface defining the available persistent stream sequencing policies as string constants.
SourcingEventMessageStream	A MessageStream implementation backed by a ResultStream of SourceEventsResponses from Axon Server, translating the SourceEventsResponses into EventMessages as it moves along.
StreamingEventMessageStream	A MessageStream implementation backed by a ResultStream of StreamEventsResponses from Axon Server, translating the StreamEventsResponses into EventMessages as it moves along.
TaggedEventConverter	Wrapper around the Axon Framework EventConverter that can convert TaggedEventMessages (Axon Framework representation) to TaggedEvents (Axon Server representation).