Uses of Interface
org.axonframework.eventhandling.TrackedEventMessage

Packages that use TrackedEventMessage

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	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.inmemory
org.axonframework.kafka.eventhandling.consumer

Uses of TrackedEventMessage in org.axonframework.config

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

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

Classes in org.axonframework.eventhandling that implement TrackedEventMessage

Modifier and Type	Class and Description
class	GenericTrackedEventMessage<T> Generic implementation of a TrackedEventMessage.

Constructor parameters in org.axonframework.eventhandling with type arguments of type TrackedEventMessage

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

Classes in org.axonframework.eventsourcing that implement TrackedEventMessage

Modifier and Type	Class and Description
class	GenericTrackedDomainEventMessage<T> Generic implementation of a DomainEventMessage that is also a TrackedEventMessage.

Methods in org.axonframework.eventsourcing that return types with arguments of type TrackedEventMessage

Modifier and Type	Method and Description
Stream<? extends TrackedEventMessage<?>>	FilteringEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock)

Uses of TrackedEventMessage in org.axonframework.eventsourcing.eventstore

Methods in org.axonframework.eventsourcing.eventstore that return TrackedEventMessage

Modifier and Type	Method and Description
static <T> TrackedEventMessage<T>	EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage, TrackingToken trackingToken) Convert an EventMessage to a TrackedEventMessage using the given trackingToken.

Methods in org.axonframework.eventsourcing.eventstore that return types with arguments of type TrackedEventMessage

Modifier and Type	Method and Description
Stream<? extends TrackedEventMessage<?>>	SequenceEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock)
Stream<? extends TrackedEventMessage<?>>	EventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock) Open an event stream containing all events stored since given tracking token.
Stream<? extends TrackedEventMessage<?>>	AbstractEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock)
static Stream<TrackedEventMessage<?>>	EventUtils.upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream, Serializer serializer, EventUpcaster upcasterChain, boolean skipUnknownTypes) Upcasts and deserializes the given eventEntryStream using the given serializer and upcasterChain.

Uses of TrackedEventMessage in org.axonframework.eventsourcing.eventstore.inmemory

Methods in org.axonframework.eventsourcing.eventstore.inmemory that return types with arguments of type TrackedEventMessage

Modifier and Type	Method and Description
Stream<? extends TrackedEventMessage<?>>	InMemoryEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock) Open an event stream containing all events stored since given tracking token.

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

Methods in org.axonframework.kafka.eventhandling.consumer that return TrackedEventMessage

Modifier and Type	Method and Description
TrackedEventMessage<?>	KafkaMessageStream.nextAvailable()
TrackedEventMessage<?>	KafkaEventMessage.value()

Methods in org.axonframework.kafka.eventhandling.consumer that return types with arguments of type TrackedEventMessage

Modifier and Type	Method and Description
MessageStream<TrackedEventMessage<?>>	KafkaMessageSource.openStream(TrackingToken trackingToken)
Optional<TrackedEventMessage<?>>	KafkaMessageStream.peek()
MessageStream<TrackedEventMessage<?>>	Fetcher.start(KafkaTrackingToken token) Open a stream of messages, starting at the position indicated by the given token.
MessageStream<TrackedEventMessage<?>>	AsyncFetcher.start(KafkaTrackingToken token)

Constructors in org.axonframework.kafka.eventhandling.consumer with parameters of type TrackedEventMessage

Constructor and Description
KafkaEventMessage(TrackedEventMessage<?> eventMessage, int partition, long offset, long timestamp)