Uses of Interface
org.axonframework.eventhandling.TrackedEventMessage

Packages that use TrackedEventMessage

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

Classes in org.axonframework.eventhandling that implement TrackedEventMessage

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

Methods in org.axonframework.eventhandling that return TrackedEventMessage

Modifier and Type	Method	Description
static <T> TrackedEventMessage<T>	EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage, TrackingToken trackingToken)	Convert an EventMessage to a TrackedEventMessage using the given trackingToken.
TrackedEventMessage<T>	TrackedEventMessage.withTrackingToken(TrackingToken trackingToken)	Creates a copy of this message with the given trackingToken to replace the one in this message.

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

Modifier and Type	Method	Description
Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken>	TrackingEventProcessorConfiguration.getInitialTrackingToken()	Return the builder function of the initial TrackingToken.
StreamableMessageSource<? extends TrackedEventMessage<?>>	TrackingEventProcessor.getMessageSource()	Returns the StreamableMessageSource this processor is using
static Stream<TrackedEventMessage<?>>	EventUtils.upcastAndDeserializeTrackedEvents(Stream<? extends TrackedEventData<?>> eventEntryStream, Serializer serializer, EventUpcaster upcasterChain)	Upcasts and deserializes the given eventEntryStream using the given serializer and upcasterChain.

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

Modifier and Type	Method	Description
MultiStreamableMessageSource.Builder	MultiStreamableMessageSource.Builder.addMessageSource(String messageSourceId, StreamableMessageSource<TrackedEventMessage<?>> messageSource)	Adds a message source to the list of sources.
TrackingEventProcessorConfiguration	TrackingEventProcessorConfiguration.andInitialTrackingToken(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenBuilder)	Sets the builder to use to create the initial TrackingToken.
TrackingEventProcessor.Builder	TrackingEventProcessor.Builder.messageSource(StreamableMessageSource<TrackedEventMessage<?>> messageSource)	Sets the StreamableMessageSource (e.g. the EventBus) which this EventProcessor will track.
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)
MultiStreamableMessageSource.Builder	MultiStreamableMessageSource.Builder.trackedEventComparator(Comparator<Map.Entry<String,TrackedEventMessage<?>>> trackedEventComparator)	Overrides the default trackedEventComparator.

Uses of TrackedEventMessage in org.axonframework.eventhandling.pooled

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

Modifier and Type	Method	Description
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.initialToken(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialToken)	Specifies the Function used to generate the initial TrackingTokens.
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.messageSource(StreamableMessageSource<TrackedEventMessage<?>> messageSource)	Sets the StreamableMessageSource (e.g. the EventStore) which this EventProcessor will track.
void	PooledStreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier)
<R> void	PooledStreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier, R resetContext)