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 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 interface org.springframework.integration.support.ErrorMessageStrategy