Package org.axonframework.messaging.eventhandling.processing.streaming.segmenting
package org.axonframework.messaging.eventhandling.processing.streaming.segmenting
-
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.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.Implementation of theEventTrackerStatus, providing simply modification methods to switch from oneEventTrackerStatusvalue object to another.Wrapper around anEventTrackerStatus, delegating all calls to adelegate.