Uses of Class
org.axonframework.eventhandling.Segment

Packages that use Segment

Package	Description
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.deadletter
org.axonframework.eventhandling.tokenstore
org.axonframework.eventhandling.tokenstore.jdbc
org.axonframework.eventhandling.tokenstore.jpa
org.axonframework.eventhandling.tokenstore.legacyjpa
org.axonframework.modelling.saga

Uses of Segment in org.axonframework.eventhandling

Fields in org.axonframework.eventhandling declared as Segment

Modifier and Type	Field	Description
static final Segment	Segment.ROOT_SEGMENT	Represents the Segment that matches against all input, but can be split to start processing elements in parallel.

Methods in org.axonframework.eventhandling that return Segment

Modifier and Type	Method	Description
static Segment	Segment.computeSegment(int segmentId, int... availableSegmentIds)	Creates a Segment instance for the given segmentId based on the given availableSegmentsIds.
static Segment[]	Segment.computeSegments(int... segments)	Compute the Segment's from a given list of segmentId's.
Segment	EventTrackerStatus.getSegment()	The segment for which this status is valid.
Segment	TrackerStatus.getSegment()
Segment	WrappedTrackerStatus.getSegment()
Segment	Segment.mergedWith(Segment other)	Calculates the Segment that represents the merger of this segment with the given other segment.
Segment[]	Segment.split()	Returns an array with two segments with a corresponding mask. The first entry contains the original segmentId, with the newly calculated mask.

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

Modifier and Type	Method	Description
protected Set<Segment>	TrackingEventProcessor.processingSegments(TrackingToken token, Segment segment)	Indicates whether the eventMessage identified with given token should be processed as part of the given segment.
static List<Segment>	Segment.splitBalanced(Segment segment, int numberOfTimes)	Split a given Segment n-times in round robin fashion.

Methods in org.axonframework.eventhandling with parameters of type Segment

Modifier and Type	Method	Description
protected boolean	AbstractEventProcessor.canHandle(EventMessage<?> eventMessage, Segment segment)	Indicates whether the processor can/should handle the given eventMessage for the given segment.
boolean	EventHandlerInvoker.canHandle(EventMessage<?> eventMessage, Segment segment)	Check whether or not this invoker has handlers that can handle the given eventMessage for a given segment.
boolean	MultiEventHandlerInvoker.canHandle(EventMessage<?> eventMessage, Segment segment)
boolean	SimpleEventHandlerInvoker.canHandle(EventMessage<?> eventMessage, Segment segment)
int	Segment.compareTo(Segment that)
void	EventHandlerInvoker.handle(EventMessage<?> message, Segment segment)	Handle the given message for the given segment.
void	MultiEventHandlerInvoker.handle(EventMessage<?> message, Segment segment)
void	SimpleEventHandlerInvoker.handle(EventMessage<?> message, Segment segment)
boolean	Segment.isMergeableWith(Segment other)	Indicates whether this segment can be merged with the given other segment.
Segment	Segment.mergedWith(Segment other)	Calculates the Segment that represents the merger of this segment with the given other segment.
protected void	TrackingEventProcessor.processingLoop(Segment segment)	Fetch and process event batches continuously for as long as the processor is not shutting down.
protected Set<Segment>	TrackingEventProcessor.processingSegments(TrackingToken token, Segment segment)	Indicates whether the eventMessage identified with given token should be processed as part of the given segment.
default void	EventHandlerInvoker.segmentReleased(Segment segment)	This is a way for an event processor to communicate that a segment which was being processed is released.
protected boolean	SimpleEventHandlerInvoker.sequencingPolicyMatchesSegment(EventMessage<?> message, Segment segment)
static TrackerStatus[]	TrackerStatus.split(Segment segment, TrackingToken trackingToken)	Split the given segment and trackingToken in two.
static List<Segment>	Segment.splitBalanced(Segment segment, int numberOfTimes)	Split a given Segment n-times in round robin fashion.

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

Modifier and Type	Method	Description
protected boolean	TrackingEventProcessor.canHandle(EventMessage<?> eventMessage, Collection<Segment> segments)	Indicates whether any of the components handling events for this Processor are able to handle the given eventMessage for any of the given segments.
protected void	AbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages, UnitOfWork<? extends EventMessage<?>> unitOfWork, Collection<Segment> processingSegments)	Process a batch of events.

Constructors in org.axonframework.eventhandling with parameters of type Segment

Modifier	Constructor	Description
	TrackerStatus(Segment segment, boolean caughtUp, TrackingToken trackingToken, Throwable errorState)	Construct a EventTrackerStatus to portray the status of the given segment and trackingToken.
	TrackerStatus(Segment segment, TrackingToken trackingToken)	Construct a EventTrackerStatus to portray the status of the given segment and trackingToken.

Uses of Segment in org.axonframework.eventhandling.deadletter

Methods in org.axonframework.eventhandling.deadletter with parameters of type Segment

Modifier and Type	Method	Description
void	DeadLetteringEventHandlerInvoker.handle(EventMessage<?> message, Segment segment)
void	DeadLetteringEventHandlerInvoker.segmentReleased(Segment segment)

Uses of Segment in org.axonframework.eventhandling.tokenstore

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

Modifier and Type	Method	Description
default List<Segment>	TokenStore.fetchAvailableSegments(String processorName)	Returns a List of known available segments for a given processorName.

Methods in org.axonframework.eventhandling.tokenstore with parameters of type Segment

Modifier and Type	Method	Description
default TrackingToken	TokenStore.fetchToken(String processorName, Segment segment)	Returns the last stored token for the given processorName and segment.

Uses of Segment in org.axonframework.eventhandling.tokenstore.jdbc

Methods in org.axonframework.eventhandling.tokenstore.jdbc that return types with arguments of type Segment

Modifier and Type	Method	Description
List<Segment>	JdbcTokenStore.fetchAvailableSegments(String processorName)

Methods in org.axonframework.eventhandling.tokenstore.jdbc with parameters of type Segment

Modifier and Type	Method	Description
TrackingToken	JdbcTokenStore.fetchToken(String processorName, Segment segment)
protected TrackingToken	JdbcTokenStore.loadToken(Connection connection, ResultSet resultSet, String processorName, Segment segment)	Tries loading an existing token owned by a processor with given processorName and segment.
protected void	JdbcTokenStore.validateSegment(String processorName, Segment segment)	Validate a segment by checking for the existence of a split or merge candidate segment.

Uses of Segment in org.axonframework.eventhandling.tokenstore.jpa

Methods in org.axonframework.eventhandling.tokenstore.jpa that return types with arguments of type Segment

Modifier and Type	Method	Description
List<Segment>	JpaTokenStore.fetchAvailableSegments(String processorName)

Methods in org.axonframework.eventhandling.tokenstore.jpa with parameters of type Segment

Modifier and Type	Method	Description
TrackingToken	JpaTokenStore.fetchToken(String processorName, Segment segment)
protected TokenEntry	JpaTokenStore.loadToken(String processorName, Segment segment, jakarta.persistence.EntityManager entityManager)	Tries loading an existing token owned by a processor with given processorName and segment.

Uses of Segment in org.axonframework.eventhandling.tokenstore.legacyjpa

Methods in org.axonframework.eventhandling.tokenstore.legacyjpa that return types with arguments of type Segment

Modifier and Type	Method	Description
List<Segment>	JpaTokenStore.fetchAvailableSegments(String processorName)	Deprecated.

Methods in org.axonframework.eventhandling.tokenstore.legacyjpa with parameters of type Segment

Modifier and Type	Method	Description
TrackingToken	JpaTokenStore.fetchToken(String processorName, Segment segment)	Deprecated.
protected TokenEntry	JpaTokenStore.loadToken(String processorName, Segment segment, javax.persistence.EntityManager entityManager)	Deprecated. Tries loading an existing token owned by a processor with given processorName and segment.

Uses of Segment in org.axonframework.modelling.saga

Methods in org.axonframework.modelling.saga with parameters of type Segment

Modifier and Type	Method	Description
boolean	AnnotatedSagaManager.canHandle(EventMessage<?> eventMessage, Segment segment)
protected String	AbstractSagaManager.createSagaIdentifier(Segment segment)	Creates a Saga identifier that will cause a Saga instance to be considered part of the given segment.
void	AbstractSagaManager.handle(EventMessage<?> event, Segment segment)
protected boolean	AbstractSagaManager.matchesSegment(Segment segment, String sagaId)	Checks whether the given sagaId matches with the given segment.