Package io.mats3.api.intercept
Interface MatsStageInterceptor.StageCompletedContext
- All Superinterfaces:
CommonCompletedContext
,MatsStageInterceptor.StageCommonContext
,MatsStageInterceptor.StageInterceptContext
- Enclosing interface:
- MatsStageInterceptor
public static interface MatsStageInterceptor.StageCompletedContext
extends MatsStageInterceptor.StageCommonContext, CommonCompletedContext
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic enum
The main result of the Stage Processing - if the stage also initiated messages, this will be known bygetStageInitiatedMessages()
being non-empty.Nested classes/interfaces inherited from interface io.mats3.api.intercept.CommonCompletedContext
CommonCompletedContext.MatsMeasurement, CommonCompletedContext.MatsTimingMeasurement
-
Method Summary
Modifier and TypeMethodDescriptionMethods inherited from interface io.mats3.api.intercept.CommonCompletedContext
getDbCommitNanos, getMeasurements, getMessageSystemCommitNanos, getOutgoingMessages, getSumEnvelopeSerializationAndCompressionNanos, getSumMessageSystemProductionAndSendNanos, getThrowable, getTimingMeasurements, getTotalExecutionNanos, getUserLambdaNanos
Methods inherited from interface io.mats3.api.intercept.MatsStageInterceptor.StageCommonContext
getDataAndStateDeserializationNanos, getDataSerializedSize, getEndpointEnteredTimestamp, getEnvelopeDecompressionNanos, getEnvelopeDeserializationNanos, getEnvelopeSerializedSize, getEnvelopeWireSize, getIncomingData, getIncomingMessageType, getIncomingSameStackHeightExtraState, getIncomingState, getInterceptContextAttribute, getMessageSystemDeconstructNanos, getMessageSystemTotalWireSize, getPrecedingSameStackHeightOutgoingTimestamp, getProcessContext, getStateSerializedSize, getTotalPreprocessAndDeserializeNanos, putInterceptContextAttribute
Methods inherited from interface io.mats3.api.intercept.MatsStageInterceptor.StageInterceptContext
getStage, getStartedInstant, getStartedNanoTime
-
Method Details
-
getProcessResult
MatsStageInterceptor.StageCompletedContext.ProcessResult getProcessResult()- Returns:
- The type of the main result of the Stage Processing - which do not include any stage-initiations,
look at
getStageInitiatedMessages()
for that.
-
getStageResultMessage
Optional<MatsOutgoingMessage.MatsSentOutgoingMessage> getStageResultMessage()- Returns:
- the Reply, Next or Goto outgoing message, it this was the
ProcessingResult
. Otherwise,Optional.empty()
. The message will be ofDispatchType.STAGE
.
-
getStageRequestMessages
List<MatsOutgoingMessage.MatsSentOutgoingMessage> getStageRequestMessages()- Returns:
- the outgoing Requests, if this was the
MatsStageInterceptor.StageCompletedContext.ProcessResult
. Otherwise, an empty list. The messages will be ofDispatchType.STAGE
.
-
getStageInitiatedMessages
List<MatsOutgoingMessage.MatsSentOutgoingMessage> getStageInitiatedMessages()- Returns:
- all stage-initiated messages, which are of
DispatchType.STAGE_INIT
.
-