org.springframework.integration.kafka.support

Class RawRecordHeaderErrorMessageStrategy

java.lang.Object

org.springframework.integration.kafka.support.RawRecordHeaderErrorMessageStrategy

All Implemented Interfaces:

ErrorMessageStrategy

public class RawRecordHeaderErrorMessageStrategy
extends Object
implements ErrorMessageStrategy

ErrorMessageStrategy extension that adds the raw record as a header to the ErrorMessage.

Since:

5.4

Author:

Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
RawRecordHeaderErrorMessageStrategy()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RawRecordHeaderErrorMessageStrategy

public RawRecordHeaderErrorMessageStrategy()

Method Detail

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.