Class KinesisMessageHeaderErrorMessageStrategy
java.lang.Object
org.springframework.integration.aws.inbound.kinesis.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 AwsHeaders.RAW_RECORD
header by the value from the the provided
AttributeAccessor
.- Since:
- 2.0
- Author:
- Artem Bilan
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.springframework.messaging.support.ErrorMessage
buildErrorMessage
(Throwable throwable, org.springframework.core.AttributeAccessor context)
-
Constructor Details
-
KinesisMessageHeaderErrorMessageStrategy
public KinesisMessageHeaderErrorMessageStrategy()
-
-
Method Details
-
buildErrorMessage
public org.springframework.messaging.support.ErrorMessage buildErrorMessage(Throwable throwable, org.springframework.core.AttributeAccessor context) - Specified by:
buildErrorMessage
in interfaceorg.springframework.integration.support.ErrorMessageStrategy
-