public class AmqpMessageHeaderErrorMessageStrategy extends java.lang.Object implements ErrorMessageStrategy
ErrorMessageStrategy
extension that adds the raw AMQP message as
a header to the ErrorMessage
.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
AMQP_RAW_MESSAGE
Header name/retry context variable for the raw received message.
|
Constructor and Description |
---|
AmqpMessageHeaderErrorMessageStrategy() |
Modifier and Type | Method and Description |
---|---|
org.springframework.messaging.support.ErrorMessage |
buildErrorMessage(java.lang.Throwable throwable,
org.springframework.core.AttributeAccessor context)
Build the error message.
|
public static final java.lang.String AMQP_RAW_MESSAGE
public AmqpMessageHeaderErrorMessageStrategy()
public org.springframework.messaging.support.ErrorMessage buildErrorMessage(java.lang.Throwable throwable, @Nullable org.springframework.core.AttributeAccessor context)
ErrorMessageStrategy
buildErrorMessage
in interface ErrorMessageStrategy
throwable
- the payload.context
- the attributes.