Package io.mats3.api.intercept

Interface MatsStageInterceptor.MatsStageInterceptOutgoingMessages

All Superinterfaces:

MatsStageInterceptor

All Known Implementing Classes:

LocalStatsMatsInterceptor

Enclosing interface:

MatsStageInterceptor

public static interface MatsStageInterceptor.MatsStageInterceptOutgoingMessages
extends MatsStageInterceptor

While still within the stage process context, this interception enables modifying outgoing messages from the user lambda, setting trace properties, adding "sideloads", deleting a message, or initiating additional messages.

Pulled out in separate interface, so that we don't need to invoke it if the interceptor doesn't need it.

Nested Class Summary

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

MatsStageInterceptor.MatsStageInterceptOutgoingMessages, MatsStageInterceptor.MatsStageInterceptUserLambda, MatsStageInterceptor.StageCommonContext, MatsStageInterceptor.StageCompletedContext, MatsStageInterceptor.StageInterceptContext, MatsStageInterceptor.StageInterceptOutgoingMessageContext, MatsStageInterceptor.StageInterceptUserLambdaContext, MatsStageInterceptor.StagePreprocessAndDeserializeErrorContext, MatsStageInterceptor.StageReceivedContext

Method Summary

Modifier and Type	Method	Description
void	stageInterceptOutgoingMessages(MatsStageInterceptor.StageInterceptOutgoingMessageContext context)

Methods inherited from interface io.mats3.api.intercept.MatsStageInterceptor

stageCompleted, stageCompletedNextDirect, stagePreprocessAndDeserializeError, stageReceived

Method Details

stageInterceptOutgoingMessages

void stageInterceptOutgoingMessages(MatsStageInterceptor.StageInterceptOutgoingMessageContext context)