Package io.mats3

Class MatsEndpoint.MatsRefuseMessageException

java.lang.Object
java.lang.Throwable
java.lang.Exception
io.mats3.MatsEndpoint.MatsRefuseMessageException
All Implemented Interfaces:
Serializable
Enclosing interface:
MatsEndpoint<R,S>

public static class MatsEndpoint.MatsRefuseMessageException extends Exception
Can be thrown by the MatsEndpoint.ProcessLambda of the MatsStages to denote that it would prefer this message to be instantly put on a Dead Letter Queue (the stage processing, including any database actions, will still be rolled back as with any other exception thrown out of a ProcessLambda). This is just advisory - the message might still be presented a number of times to the MatsStage in question even though the stage throws MatsRefuseMessageException every time.
See Also:
  • Constructor Details

    • MatsRefuseMessageException

      public MatsRefuseMessageException(String message, Throwable cause)
    • MatsRefuseMessageException

      public MatsRefuseMessageException(String message)