Uses of Interface
org.axonframework.messaging.StreamableMessageSource

Packages that use StreamableMessageSource

Package	Description
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.pooled

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)