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 Classes

Modifier and Type	Interface	Description
static enum	MatsStageInterceptor.StageCompletedContext.ProcessResult	The main result of the Stage Processing - if the stage also initiated messages, this will be known by getStageInitiatedMessages() being non-empty.

Nested classes/interfaces inherited from interface io.mats3.api.intercept.CommonCompletedContext

CommonCompletedContext.MatsMeasurement, CommonCompletedContext.MatsTimingMeasurement

Method Summary

Modifier and Type	Method	Description
MatsStageInterceptor.StageCompletedContext.ProcessResult	getProcessResult()
List<MatsOutgoingMessage.MatsSentOutgoingMessage>	getStageInitiatedMessages()
List<MatsOutgoingMessage.MatsSentOutgoingMessage>	getStageRequestMessages()
Optional<MatsOutgoingMessage.MatsSentOutgoingMessage>	getStageResultMessage()

Methods 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 of DispatchType.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 of DispatchType.STAGE.

getStageInitiatedMessages

List<MatsOutgoingMessage.MatsSentOutgoingMessage> getStageInitiatedMessages()

Returns:

all stage-initiated messages, which are of DispatchType.STAGE_INIT.