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 |
Modifier and Type | Field and Description |
---|---|
static Segment |
Segment.ROOT_SEGMENT
Represents the Segment that matches against all input, but can be split to start processing elements in parallel.
|
Modifier and Type | Method and 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 |
WrappedTrackerStatus.getSegment() |
Segment |
TrackerStatus.getSegment() |
Segment |
EventTrackerStatus.getSegment()
The segment for which this status is valid.
|
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. |
Modifier and Type | Method and 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. |
Modifier and Type | Method and Description |
---|---|
boolean |
SimpleEventHandlerInvoker.canHandle(EventMessage<?> eventMessage,
Segment segment) |
boolean |
MultiEventHandlerInvoker.canHandle(EventMessage<?> eventMessage,
Segment 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 . |
protected boolean |
AbstractEventProcessor.canHandle(EventMessage<?> eventMessage,
Segment segment)
Indicates whether the processor can/should handle the given
eventMessage for the given segment . |
int |
Segment.compareTo(Segment that) |
void |
SimpleEventHandlerInvoker.handle(EventMessage<?> message,
Segment segment) |
void |
MultiEventHandlerInvoker.handle(EventMessage<?> message,
Segment segment) |
void |
EventHandlerInvoker.handle(EventMessage<?> message,
Segment segment)
Handle the given
message for the given 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. |
Modifier and Type | Method and 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.
|
Constructor and Description |
---|
TrackerStatus(Segment segment,
boolean caughtUp,
TrackingToken trackingToken,
Throwable errorState)
|
TrackerStatus(Segment segment,
TrackingToken trackingToken)
|
Modifier and Type | Method and Description |
---|---|
void |
DeadLetteringEventHandlerInvoker.handle(EventMessage<?> message,
Segment segment) |
void |
DeadLetteringEventHandlerInvoker.segmentReleased(Segment segment) |
Modifier and Type | Method and Description |
---|---|
default List<Segment> |
TokenStore.fetchAvailableSegments(String processorName)
Returns a List of known available
segments for a given processorName . |
Modifier and Type | Method and Description |
---|---|
default TrackingToken |
TokenStore.fetchToken(String processorName,
Segment segment)
|
Modifier and Type | Method and Description |
---|---|
List<Segment> |
JdbcTokenStore.fetchAvailableSegments(String processorName) |
Modifier and Type | Method and 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. |
Modifier and Type | Method and Description |
---|---|
List<Segment> |
JpaTokenStore.fetchAvailableSegments(String processorName) |
Modifier and Type | Method and 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 . |
Modifier and Type | Method and Description |
---|---|
List<Segment> |
JpaTokenStore.fetchAvailableSegments(String processorName)
Deprecated.
|
Modifier and Type | Method and 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 . |
Modifier and Type | Method and 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 . |
Copyright © 2010–2024. All rights reserved.