Package org.axonframework.messaging.eventhandling.processing.streaming.segmenting
@NullMarked
package org.axonframework.messaging.eventhandling.processing.streaming.segmenting
Part of the Axon Messaging module. Contains classes related to streaming processor segment logic.
-
ClassDescriptionReferences a new
EventTrackerStatuswhich work just has started on.Interface describing the status of aSegmentof aStreamingEventProcessor.Represent a listener that is notified whenever theMapofEventTrackerStatus' in theStreamingEventProcessorthis component is registered to has changed.References anEventTrackerStatuswhich no active work is occurring on.A representation of a segment and corresponding mask with various capabilities.Listener invoked when a processor claims or releases aSegment.Decorator forEventHandlingComponent.Decorator implementation ofEventHandlingComponentthat uses a configurableSequencingPolicyto determine the sequence identifier for events, while delegating all other operations to an underlyingEventHandlingComponent.AnEventHandlingComponentwrapper that ensures events with the same sequence identifier are handled sequentially.SimpleSegmentChangeListenerimplementation backed by claim and release handlers.Implementation of theEventTrackerStatus, providing simply modification methods to switch from oneEventTrackerStatusvalue object to another.Wrapper around anEventTrackerStatus, delegating all calls to adelegate.