Uses of Interface
org.axonframework.messaging.StreamableMessageSource

Packages that use StreamableMessageSource

Package	Description
org.axonframework.config
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
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.kafka.eventhandling.consumer

Uses of StreamableMessageSource in org.axonframework.config

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

Modifier and Type	Method and Description
EventProcessingConfiguration	EventProcessingConfiguration.registerTrackingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source, Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration) Registers a TrackingEventProcessor with the given name, reading from the given source and using the given processorConfiguration.
EventProcessingConfiguration	EventProcessingConfiguration.registerTrackingEventProcessorUsingSource(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source) Registers a TrackingEventProcessor using the given source to read messages from.
EventHandlingConfiguration	EventHandlingConfiguration.registerTrackingProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source) Deprecated. use EventProcessingConfiguration.registerTrackingEventProcessorUsingSource(String, Function) instead
EventHandlingConfiguration	EventHandlingConfiguration.registerTrackingProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source, Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration, Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy) Deprecated. use EventProcessingConfiguration.registerTrackingEventProcessor(String, Function, Function) instead
static <S> SagaConfiguration<S>	SagaConfiguration.trackingSagaManager(Class<S> sagaType, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSourceBuilder) Initialize a configuration for a Saga of given sagaType, using a Tracking Event Processor to process incoming Events from a Message Source provided by given messageSourceBuilder.
static <S> SagaConfiguration<S>	SagaConfiguration.trackingSagaManager(Class<S> sagaType, String processingGroup, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSourceBuilder) Initialize a configuration for a Saga of given sagaType, using a Tracking Event Processor (with provided name) to process incoming Events from a Message Source provided by given messageSourceBuilder.

Uses of StreamableMessageSource in org.axonframework.eventhandling

Subinterfaces of StreamableMessageSource in org.axonframework.eventhandling

Modifier and Type	Interface and Description
interface	EventBus Specification of the mechanism on which the Event Listeners can subscribe for events and event publishers can publish their events.

Classes in org.axonframework.eventhandling that implement StreamableMessageSource

Modifier and Type	Class and Description
class	AbstractEventBus Base class for the Event Bus.
class	SimpleEventBus Implementation of the EventBus that supports streaming of events via SimpleEventBus.openStream(TrackingToken) but only of the most recently published events as it is not backed by a cache or event storage.

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

Modifier and Type	Method and Description
Function<StreamableMessageSource,TrackingToken>	TrackingEventProcessorConfiguration.getInitialTrackingToken()

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

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

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

Constructor and Description
TrackingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, StreamableMessageSource<TrackedEventMessage<?>> messageSource, TokenStore tokenStore, TransactionManager transactionManager) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
TrackingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, StreamableMessageSource<TrackedEventMessage<?>> messageSource, TokenStore tokenStore, TransactionManager transactionManager, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
TrackingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, StreamableMessageSource<TrackedEventMessage<?>> messageSource, TokenStore tokenStore, TransactionManager transactionManager, MessageMonitor<? super EventMessage<?>> messageMonitor, RollbackConfiguration rollbackConfiguration, ErrorHandler errorHandler, TrackingEventProcessorConfiguration config) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.

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.

Uses of StreamableMessageSource in org.axonframework.kafka.eventhandling.consumer

Classes in org.axonframework.kafka.eventhandling.consumer that implement StreamableMessageSource

Modifier and Type	Class and Description
class	KafkaMessageSource MessageSource implementation that reads messages from a Kafka topic.