Uses of Interface
org.axonframework.messaging.StreamableMessageSource

Packages that use StreamableMessageSource

Package	Description
org.axonframework.axonserver.connector.event.axon
org.axonframework.config
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.pooled
org.axonframework.eventsourcing	Classes related to event sourcing.
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.legacyjpa

Uses of StreamableMessageSource in org.axonframework.axonserver.connector.event.axon

Classes in org.axonframework.axonserver.connector.event.axon that implement StreamableMessageSource

Modifier and Type	Class	Description
class	AxonServerEventStore	Axon EventStore implementation that connects to the AxonIQ AxonServer Server to store and retrieve Events.

Methods in org.axonframework.axonserver.connector.event.axon that return StreamableMessageSource

Modifier and Type	Method	Description
StreamableMessageSource<TrackedEventMessage<?>>	AxonServerEventStore.createStreamableMessageSourceForContext(String context)	Creates a StreamableMessageSource that streams events from the given context, rather than the default context the application was configured to connect to.

Uses of StreamableMessageSource in org.axonframework.config

Methods in org.axonframework.config with parameters of type StreamableMessageSource

Modifier and Type	Method	Description
protected EventProcessor	EventProcessingModule.pooledStreamingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, Configuration config, StreamableMessageSource<TrackedEventMessage<?>> messageSource, EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)	Default PooledStreamingEventProcessor configuration based on this configure module.
protected EventProcessor	EventProcessingModule.trackingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, TrackingEventProcessorConfiguration config, StreamableMessageSource<TrackedEventMessage<?>> source)	Default TrackingEventProcessor configuration based on this configure module.

Method parameters in org.axonframework.config with type arguments of type StreamableMessageSource

Modifier and Type	Method	Description
EventProcessingConfigurer	EventProcessingConfigurer.configureDefaultStreamableMessageSource(Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> defaultSource)	Configures which StreamableMessageSource to use for Tracking Event Processors if none was explicitly provided.
EventProcessingConfigurer	EventProcessingModule.configureDefaultStreamableMessageSource(Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> defaultSource)
default EventProcessingConfigurer	EventProcessingConfigurer.registerPooledStreamingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource)	Registers a PooledStreamingEventProcessor in this EventProcessingConfigurer.
EventProcessingConfigurer	EventProcessingConfigurer.registerPooledStreamingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource, EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)	Registers a PooledStreamingEventProcessor in this EventProcessingConfigurer.
EventProcessingConfigurer	EventProcessingModule.registerPooledStreamingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource, EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)
EventProcessingConfigurer	EventProcessingConfigurer.registerTrackingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)	Registers a TrackingEventProcessor with given name and source within this Configurer.
EventProcessingConfigurer	EventProcessingConfigurer.registerTrackingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source, Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)	Registers a TrackingEventProcessor with given name, source and processorConfiguration within this Configurer.
EventProcessingConfigurer	EventProcessingModule.registerTrackingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)
EventProcessingConfigurer	EventProcessingModule.registerTrackingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source, Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)

Uses of StreamableMessageSource in org.axonframework.eventhandling

Classes in org.axonframework.eventhandling that implement StreamableMessageSource

Modifier and Type	Class	Description
class	MultiStreamableMessageSource	Implementation which allows for tracking processors to process messages from an arbitrary number of sources.

Methods in org.axonframework.eventhandling that return StreamableMessageSource

Modifier and Type	Method	Description
StreamableMessageSource<? extends TrackedEventMessage<?>>	TrackingEventProcessor.getMessageSource()	Returns the StreamableMessageSource this processor is using

Methods in org.axonframework.eventhandling that return types with arguments of type StreamableMessageSource

Modifier and Type	Method	Description
Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken>	TrackingEventProcessorConfiguration.getInitialTrackingToken()	Return the builder function of the initial TrackingToken.

Methods in org.axonframework.eventhandling with parameters of type StreamableMessageSource

Modifier and Type	Method	Description
MultiStreamableMessageSource.Builder	MultiStreamableMessageSource.Builder.addMessageSource(String messageSourceId, StreamableMessageSource<TrackedEventMessage<?>> messageSource)	Adds a message source to the list of sources.
TrackingEventProcessor.Builder	TrackingEventProcessor.Builder.messageSource(StreamableMessageSource<TrackedEventMessage<?>> messageSource)	Sets the StreamableMessageSource (e.g. the EventBus) which this EventProcessor will track.

Method parameters in org.axonframework.eventhandling with type arguments of type StreamableMessageSource

Modifier and Type	Method	Description
TrackingEventProcessorConfiguration	TrackingEventProcessorConfiguration.andInitialTrackingToken(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenBuilder)	Sets the builder to use to create the initial TrackingToken.
void	StreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier)	Reset tokens to the position as return by the given initialTrackingTokenSupplier.
<R> void	StreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier, R resetContext)	Reset tokens to the position as return by the given initialTrackingTokenSupplier.
void	TrackingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier)
<R> void	TrackingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier, R resetContext)

Uses of StreamableMessageSource in org.axonframework.eventhandling.pooled

Methods in org.axonframework.eventhandling.pooled with parameters of type StreamableMessageSource

Modifier and Type	Method	Description
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.messageSource(StreamableMessageSource<TrackedEventMessage<?>> messageSource)	Sets the StreamableMessageSource (e.g. the EventStore) which this EventProcessor will track.

Method parameters in org.axonframework.eventhandling.pooled with type arguments of type StreamableMessageSource

Modifier and Type	Method	Description
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.initialToken(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialToken)	Specifies the Function used to generate the initial TrackingTokens.
void	PooledStreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier)
<R> void	PooledStreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier, R resetContext)

Uses of StreamableMessageSource in org.axonframework.eventsourcing

Classes in org.axonframework.eventsourcing that implement StreamableMessageSource

Modifier and Type	Class	Description
class	MultiStreamableMessageSource	Deprecated. In favor of MultiStreamableMessageSource.

Uses of StreamableMessageSource in org.axonframework.eventsourcing.eventstore

Subinterfaces of StreamableMessageSource in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface	Description
interface	EventStore	Provides a mechanism to open streams from events in the the underlying event storage.

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

Modifier and Type	Class	Description
class	AbstractEventStore	Abstract implementation of an EventStore that uses a EventStorageEngine to store and load events.
class	EmbeddedEventStore	Implementation of an EventStore that stores and fetches events using an EventStorageEngine.

Uses of StreamableMessageSource in org.axonframework.eventsourcing.eventstore.legacyjpa

Classes in org.axonframework.eventsourcing.eventstore.legacyjpa that implement StreamableMessageSource

Modifier and Type	Class	Description
class	EmbeddedEventStore	Deprecated. in favor of using EmbeddedEventStore which moved to jakarta.