Interface MessagePostProcessor

    • Method Detail

      • postProcessMessage

        Message postProcessMessage​(Message message)
                            throws AmqpException
        Change (or replace) the message.
        Parameters:
        message - the message.
        Returns:
        the message.
        Throws:
        AmqpException - an exception.
      • postProcessMessage

        default Message postProcessMessage​(Message message,
                                           Correlation correlation)
        Change (or replace) the message and/or change its correlation data. Only applies to outbound messages.
        Parameters:
        message - the message.
        correlation - the correlation data.
        Returns:
        the message.
        Since:
        1.6.7
      • postProcessMessage

        default Message postProcessMessage​(Message message,
                                           Correlation correlation,
                                           String exchange,
                                           String routingKey)
        Change (or replace) the message and/or change its correlation data. Only applies to outbound messages.
        Parameters:
        message - the message.
        correlation - the correlation data.
        exchange - the exchange to which the message is to be sent.
        routingKey - the routing key.
        Returns:
        the message.
        Since:
        2.3.4