Class DefaultSnsPublishMessageConverter

java.lang.Object
io.awspring.cloud.sns.core.async.DefaultSnsPublishMessageConverter
All Implemented Interfaces:
SnsPublishMessageConverter

public class DefaultSnsPublishMessageConverter extends Object implements SnsPublishMessageConverter
Default implementation of SnsPublishMessageConverter.
Since:
4.1.0
Author:
Matej Nedic
  • Constructor Details

    • DefaultSnsPublishMessageConverter

      public DefaultSnsPublishMessageConverter()
    • DefaultSnsPublishMessageConverter

      public DefaultSnsPublishMessageConverter(@Nullable MessageConverter messageConverter)
  • Method Details

    • convert

      public <T> io.awspring.cloud.sns.core.async.PublishRequestMessagePair<T> convert(Message<T> originalMessage)
      Description copied from interface: SnsPublishMessageConverter
      Converts a Spring Message to a PublishRequest.
      Specified by:
      convert in interface SnsPublishMessageConverter
      Type Parameters:
      T - the message payload type
      Parameters:
      originalMessage - the message to convert
      Returns:
      a pair containing the PublishRequest and the original message
    • convert

      public <T> io.awspring.cloud.sns.core.async.PublishRequestMessagePair<T> convert(T payload, Map<String,Object> headers)
      Description copied from interface: SnsPublishMessageConverter
      Converts a payload and headers to a PublishRequest.
      Specified by:
      convert in interface SnsPublishMessageConverter
      Type Parameters:
      T - the payload type
      Parameters:
      payload - the payload to convert
      headers - the headers to include
      Returns:
      a pair containing the PublishRequest and the constructed message