Class AmqpMessageHeaderErrorMessageStrategy

java.lang.Object

org.springframework.integration.amqp.support.AmqpMessageHeaderErrorMessageStrategy

All Implemented Interfaces:

ErrorMessageStrategy

public class AmqpMessageHeaderErrorMessageStrategy
extends Object
implements ErrorMessageStrategy

An ErrorMessageStrategy extension that adds the raw AMQP message as a header to the ErrorMessage.

Since:

4.3.10

Author:

Gary Russell, Artem Bilan

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AMQP_RAW_MESSAGE	Header name/retry context variable for the raw received message.

Constructor Summary

Constructors

Constructor	Description
AmqpMessageHeaderErrorMessageStrategy()

Method Summary

Modifier and Type	Method	Description
ErrorMessage	buildErrorMessage(Throwable throwable, @Nullable AttributeAccessor context)	Build the error message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

AMQP_RAW_MESSAGE

public static final String AMQP_RAW_MESSAGE

Header name/retry context variable for the raw received message.

See Also:

• Constant Field Values

Constructor Details

AmqpMessageHeaderErrorMessageStrategy

public AmqpMessageHeaderErrorMessageStrategy()

Method Details

buildErrorMessage

public ErrorMessage buildErrorMessage(Throwable throwable,
 @Nullable AttributeAccessor context)

Description copied from interface: ErrorMessageStrategy

Build the error message.

Specified by:

buildErrorMessage in interface ErrorMessageStrategy

Parameters:

throwable - the payload.

context - the attributes.

Returns:

the ErrorMessage.