Uses of Interface
org.axonframework.messaging.eventstreaming.StreamableEventSource

Packages that use StreamableEventSource

Package	Description
io.axoniq.framework.messaging.eventstreaming	Part of the Axoniq Messaging folder.
io.axoniq.framework.messaging.transformation.events	Part of the Axoniq Messaging folder.
io.axoniq.framework.workflow.runtime.test.utils	Test-only utility components used by the workflow test fixture and configuration, such as manual execution and scheduling controls, a mutable test clock, id generation, event publication helpers, and a pretty-printing recording event store.
org.axonframework.eventsourcing.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.eventsourcing.eventstore.tracing	Event-store tracing decorators and event-sourcing-specific SpanAttributesProvider implementations.
org.axonframework.messaging.eventhandling.processing.streaming.pooled	Part of the Axon Messaging module.
org.axonframework.test.fixture	Part of the Axon Test module.

Uses of StreamableEventSource in io.axoniq.framework.messaging.eventstreaming

Classes in io.axoniq.framework.messaging.eventstreaming that implement StreamableEventSource

Modifier and Type	Class	Description
class	MultiStreamableEventSource	A StreamableEventSource implementation that allows streaming event processors to process events from multiple underlying event sources.

Methods in io.axoniq.framework.messaging.eventstreaming with parameters of type StreamableEventSource

Modifier and Type	Method	Description
MultiStreamableEventSource.SourceCollector	MultiStreamableEventSource.SourceCollector.and(String sourceName, StreamableEventSource source)	Adds another event source to the collection.
static MultiStreamableEventSource.SourceCollector	MultiStreamableEventSource.combining(String sourceName, StreamableEventSource source)	Creates a new MultiStreamableEventSource by combining multiple event sources.

Constructor parameters in io.axoniq.framework.messaging.eventstreaming with type arguments of type StreamableEventSource

Modifier	Constructor	Description
protected	MultiStreamableEventSource(Map<String,StreamableEventSource> eventSources, Comparator<MessageStream.Entry<EventMessage>> eventComparator)	Constructs a MultiStreamableEventSource from the collected sources and comparator.

Uses of StreamableEventSource in io.axoniq.framework.messaging.transformation.events

Classes in io.axoniq.framework.messaging.transformation.events that implement StreamableEventSource

Modifier and Type	Class	Description
final class	TransformingEventStore	EventStore decorator that applies an EventTransformerChain to every read path (entity loads, DCB reads, tracking-processor reads, ...).

Uses of StreamableEventSource in io.axoniq.framework.workflow.runtime.test.utils

Classes in io.axoniq.framework.workflow.runtime.test.utils that implement StreamableEventSource

Modifier and Type	Class	Description
class	PrettyPrintingRecordingEventStore	Pretty printing event store used for testing.

Uses of StreamableEventSource in org.axonframework.eventsourcing.eventstore

Subinterfaces of StreamableEventSource in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface	Description
interface	EventStore	Infrastructure component providing the means to start an EventStoreTransaction to append events and event source models from the underlying storage solution.

Classes in org.axonframework.eventsourcing.eventstore that implement StreamableEventSource

Modifier and Type	Class	Description
class	InterceptingEventStore	Decorator around the EventStore intercepting all events before they are appended or published with dispatch interceptors.
class	StorageEngineBackedEventStore	An EventStore implementation which uses an EventStorageEngine as its storage solution.

Uses of StreamableEventSource in org.axonframework.eventsourcing.eventstore.tracing

Classes in org.axonframework.eventsourcing.eventstore.tracing that implement StreamableEventSource

Modifier and Type	Class	Description
final class	TracingEventStore	Type-preserving tracing decorator for EventStore.

Uses of StreamableEventSource in org.axonframework.messaging.eventhandling.processing.streaming.pooled

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled that return StreamableEventSource

Modifier and Type	Method	Description
StreamableEventSource	PooledStreamingEventProcessorConfiguration.eventSource()	Returns the StreamableEventSource used to track events.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled with parameters of type StreamableEventSource

Modifier and Type	Method	Description
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.eventSource(StreamableEventSource eventSource)	Sets the StreamableEventSource (e.g. the EventStore) which this EventProcessor will track.

Uses of StreamableEventSource in org.axonframework.test.fixture

Classes in org.axonframework.test.fixture that implement StreamableEventSource

Modifier and Type	Class	Description
class	RecordingEventStore	An EventStore implementation recording all the events that are published.