Class DefaultSnsPublishMessageConverter
java.lang.Object
io.awspring.cloud.sns.core.async.DefaultSnsPublishMessageConverter
- All Implemented Interfaces:
SnsPublishMessageConverter
Default implementation of
SnsPublishMessageConverter.- Since:
- 4.1.0
- Author:
- Matej Nedic
-
Constructor Summary
ConstructorsConstructorDescriptionDefaultSnsPublishMessageConverter(@Nullable MessageConverter messageConverter) -
Method Summary
Modifier and TypeMethodDescription<T> io.awspring.cloud.sns.core.async.PublishRequestMessagePair<T> Converts a Spring Message to a PublishRequest.<T> io.awspring.cloud.sns.core.async.PublishRequestMessagePair<T> Converts a payload and headers to a PublishRequest.
-
Constructor Details
-
DefaultSnsPublishMessageConverter
public DefaultSnsPublishMessageConverter() -
DefaultSnsPublishMessageConverter
-
-
Method Details
-
convert
public <T> io.awspring.cloud.sns.core.async.PublishRequestMessagePair<T> convert(Message<T> originalMessage) Description copied from interface:SnsPublishMessageConverterConverts a Spring Message to a PublishRequest.- Specified by:
convertin interfaceSnsPublishMessageConverter- 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:SnsPublishMessageConverterConverts a payload and headers to a PublishRequest.- Specified by:
convertin interfaceSnsPublishMessageConverter- Type Parameters:
T- the payload type- Parameters:
payload- the payload to convertheaders- the headers to include- Returns:
- a pair containing the PublishRequest and the constructed message
-