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

Packages that use StreamableEventSource

Package	Description
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.messaging.eventhandling.processing.streaming.pooled	Part of the Axon Messaging module.
org.axonframework.messaging.eventstreaming	Part of the Axon Messaging module.
org.axonframework.test.fixture	Part of the Axon Test module.

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.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.messaging.eventstreaming

Classes in org.axonframework.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 org.axonframework.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 org.axonframework.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 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.