Package io.awspring.cloud.sqs.support.converter

Class SqsMessagingMessageConverter

java.lang.Object

io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>

io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter

All Implemented Interfaces:

ContextAwareMessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>, MessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>

public class SqsMessagingMessageConverter
extends AbstractMessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>

MessagingMessageConverter implementation for converting SQS Message instances to Spring Messaging Message instances.

Since:

3.0

Author:

Tomaz Fernandes

See Also:

• SqsHeaderMapper
• SqsMessageConversionContext

Constructor Summary

Constructors

Constructor	Description
SqsMessagingMessageConverter()

Method Summary

Modifier and Type	Method	Description
protected HeaderMapper<software.amazon.awssdk.services.sqs.model.Message>	createDefaultHeaderMapper()
MessageConversionContext	createMessageConversionContext()	An optional context to be used in the conversion process.
protected software.amazon.awssdk.services.sqs.model.Message	doConvertMessage(software.amazon.awssdk.services.sqs.model.Message messageWithHeaders, Object payload)
protected Object	getPayloadToDeserialize(software.amazon.awssdk.services.sqs.model.Message message)

Methods inherited from class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter

fromMessagingMessage, getPayloadMessageConverter, setHeaderMapper, setObjectMapper, setPayloadMessageConverter, setPayloadTypeHeader, setPayloadTypeHeaderValueFunction, setPayloadTypeMapper, toMessagingMessage

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.awspring.cloud.sqs.support.converter.ContextAwareMessagingMessageConverter

fromMessagingMessage, toMessagingMessage

Constructor Details

SqsMessagingMessageConverter

public SqsMessagingMessageConverter()

Method Details

createDefaultHeaderMapper

protected HeaderMapper<software.amazon.awssdk.services.sqs.model.Message> createDefaultHeaderMapper()

Specified by:

createDefaultHeaderMapper in class AbstractMessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>

getPayloadToDeserialize

protected Object getPayloadToDeserialize(software.amazon.awssdk.services.sqs.model.Message message)

Specified by:

getPayloadToDeserialize in class AbstractMessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>

createMessageConversionContext

public MessageConversionContext createMessageConversionContext()

Description copied from interface: ContextAwareMessagingMessageConverter

An optional context to be used in the conversion process.

Specified by:

createMessageConversionContext in interface ContextAwareMessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>

Overrides:

createMessageConversionContext in class AbstractMessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>

Returns:

the context.

doConvertMessage

protected software.amazon.awssdk.services.sqs.model.Message doConvertMessage(software.amazon.awssdk.services.sqs.model.Message messageWithHeaders,
 Object payload)

Specified by:

doConvertMessage in class AbstractMessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message>