Class KinesisMessageHeaderErrorMessageStrategy

java.lang.Object

io.awspring.cloud.kinesis.integration.KinesisMessageHeaderErrorMessageStrategy

All Implemented Interfaces:

org.springframework.integration.support.ErrorMessageStrategy

public class KinesisMessageHeaderErrorMessageStrategy
extends Object
implements org.springframework.integration.support.ErrorMessageStrategy

The ErrorMessageStrategy implementation to build an ErrorMessage with the KinesisHeaders.RAW_RECORD header as the value from the provided AttributeAccessor.

Since:

4.0

Author:

Artem Bilan

Constructor Summary

Constructors

Constructor	Description
KinesisMessageHeaderErrorMessageStrategy()

Method Summary

Modifier and Type	Method	Description
ErrorMessage	buildErrorMessage(Throwable throwable, AttributeAccessor context)

Methods inherited from class java.lang.Object

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

Constructor Details

KinesisMessageHeaderErrorMessageStrategy

public KinesisMessageHeaderErrorMessageStrategy()

Method Details

buildErrorMessage

public ErrorMessage buildErrorMessage(Throwable throwable,
 AttributeAccessor context)

Specified by:

buildErrorMessage in interface org.springframework.integration.support.ErrorMessageStrategy