Package | Description |
---|---|
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
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 |
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) |
protected boolean |
AbstractEventProcessor.canHandle(EventMessage<?> eventMessage,
Segment segment)
Indicates whether the processor can/should handle the given
eventMessage for the given 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 . |
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 . |
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.
|
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–2020. All rights reserved.