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.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.

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

Uses of StreamableMessageSource in org.axonframework.eventhandling

Classes in org.axonframework.eventhandling that implement StreamableMessageSource

Modifier and Type	Class and 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 and 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 and Description
Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken>	TrackingEventProcessorConfiguration.getInitialTrackingToken()

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

Modifier and Type	Method and 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.

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

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

Uses of StreamableMessageSource in org.axonframework.eventhandling.pooled

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

Modifier and Type	Method and Description
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.messageSource(StreamableMessageSource<TrackedEventMessage<?>> messageSource) Sets the StreamableMessageSource (e.g.

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

Modifier and Type	Method and 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.eventstore

Subinterfaces of StreamableMessageSource in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface and 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 and 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.