Uses of Interface
org.axonframework.eventhandling.TrackedEventMessage

Packages that use TrackedEventMessage

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	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

Uses of TrackedEventMessage in org.axonframework.axonserver.connector.event.axon

Methods in org.axonframework.axonserver.connector.event.axon that return TrackedEventMessage

Modifier and Type	Method and Description
TrackedEventMessage<?>	EventBuffer.nextAvailable()

Methods in org.axonframework.axonserver.connector.event.axon that return types with arguments of type TrackedEventMessage

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.
Optional<TrackedEventMessage<?>>	EventBuffer.peek()

Methods in org.axonframework.axonserver.connector.event.axon with parameters of type TrackedEventMessage

Modifier and Type	Method and Description
void	EventBuffer.skipMessagesWithPayloadTypeOf(TrackedEventMessage<?> ignoredMessage) Report the stream that a specific message was ignored by the 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
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.
protected EventProcessor	EventProcessingModule.pooledStreamingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, Configuration config, StreamableMessageSource<TrackedEventMessage<?>> messageSource, EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration) Default PooledStreamingEventProcessor configuration based on this configure module.
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.
protected EventProcessor	EventProcessingModule.trackingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, TrackingEventProcessorConfiguration config, StreamableMessageSource<TrackedEventMessage<?>> source) Default TrackingEventProcessor configuration based on this configure module.

Uses of TrackedEventMessage in org.axonframework.eventhandling

Classes in org.axonframework.eventhandling that implement TrackedEventMessage

Modifier and Type	Class and 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 and 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 and Description
Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken>	TrackingEventProcessorConfiguration.getInitialTrackingToken()
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 and 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 tracking token.
TrackingEventProcessor.Builder	TrackingEventProcessor.Builder.messageSource(StreamableMessageSource<TrackedEventMessage<?>> messageSource) Sets the StreamableMessageSource (e.g.
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.
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 and 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.
void	PooledStreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier)
<R> void	PooledStreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier, R resetContext)

Uses of TrackedEventMessage in org.axonframework.eventsourcing

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 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)

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.