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, Dongha kim, Matej Nedic

See Also:

• SqsHeaderMapper
• SqsMessageConversionContext

Constructor Summary

Constructors

Constructor	Description
SqsMessagingMessageConverter()
SqsMessagingMessageConverter(tools.jackson.databind.json.JsonMapper jsonMapper)

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 AbstractMessagingMessageConverter

configureHeaderMapper, doNotSendPayloadTypeHeader, fromMessagingMessage, getPayloadMessageConverter, isUsingDefaultPayloadTypeMapper, setHeaderMapper, setPayloadMessageConverter, setPayloadTypeHeader, setPayloadTypeHeaderValueFunction, setPayloadTypeMapper, toMessagingMessage

Methods inherited from class Object

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

Methods inherited from interface ContextAwareMessagingMessageConverter

fromMessagingMessage, toMessagingMessage

Constructor Details

SqsMessagingMessageConverter

public SqsMessagingMessageConverter(tools.jackson.databind.json.JsonMapper jsonMapper)

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>