Package io.mats3.test

Interface MatsTestBrokerInterface.MatsMessageRepresentation

Enclosing interface:
MatsTestBrokerInterface
public static interface MatsTestBrokerInterface.MatsMessageRepresentation
Representation of the Mats message that sat on the DLQ.

  • Method Details

    • getTraceId

      String getTraceId()
      Returns:
      the TraceId this message has as being a part of a "call flow" that was initiated with a TraceId.

    • getIncomingMessage

      <I> I getIncomingMessage(Class<I> type)
      The message DTO that was provided to the Mats Endpoint which DLQed the message.
      Type Parameters:
      I - the type of the message
      Parameters:
      type - the type of the message
      Returns:
      the deserialized DTO.

    • getIncomingState

      <S> S getIncomingState(Class<S> type)
      The state DTO that was provided to the Mats Endpoint which DLQed the message.
      Type Parameters:
      S - the type of the state
      Parameters:
      type - the type of the state
      Returns:
      the deserialized STO.

    • getMatsMessageId

      String getMatsMessageId()
      Returns:
      the Mats MessageId of this message.

    • getFrom

      String getFrom()
      Returns:
      who this message was from, i.e. the stage or initiator that sent the message.

    • getTo

      String getTo()
      Returns:
      who this message was for, which obviously should be the value of the endpointId that you requested in the call to MatsTestBrokerInterface.getDlqMessage(String)!