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 Description RawRecordHeaderErrorMessageStrategy()
-
Method Summary
Modifier and Type Method Description ErrorMessage
buildErrorMessage(Throwable throwable, AttributeAccessor context)
Build the error message.
-
Constructor Details
-
RawRecordHeaderErrorMessageStrategy
public RawRecordHeaderErrorMessageStrategy()
-
-
Method Details
-
buildErrorMessage
Description copied from interface:ErrorMessageStrategy
Build the error message.- Specified by:
buildErrorMessage
in interfaceErrorMessageStrategy
- Parameters:
throwable
- the payload.context
- the attributes.- Returns:
- the ErrorMessage.
-