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

Class SqsMessageConversionContext

java.lang.Object

io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext

All Implemented Interfaces:

QueueAttributesAware, SqsAsyncClientAware, AcknowledgementAwareMessageConversionContext, MessageConversionContext

public class SqsMessageConversionContext
extends Object
implements AcknowledgementAwareMessageConversionContext, SqsAsyncClientAware, QueueAttributesAware

MessageConversionContext implementation that contains SQS related properties for mapping additional MessageHeaders. Also contains a AcknowledgementCallback to be used for mapping acknowledgement related headers.

Since:

3.0

Author:

Tomaz Fernandes

See Also:

• SqsHeaderMapper
• SqsMessagingMessageConverter

Constructor Summary

Constructors

Constructor	Description
SqsMessageConversionContext()

Method Summary

Modifier and Type	Method	Description
AcknowledgementCallback<?>	getAcknowledgementCallback()
Class<?>	getPayloadClass()	An optional parameter with the payload class to be used by the conversion process.
QueueAttributes	getQueueAttributes()
software.amazon.awssdk.services.sqs.SqsAsyncClient	getSqsAsyncClient()
void	setAcknowledgementCallback(AcknowledgementCallback<?> acknowledgementCallback)
void	setPayloadClass(Class<?> payloadClass)
void	setQueueAttributes(QueueAttributes queueAttributes)	Set the QueueAttributes instance.
void	setSqsAsyncClient(software.amazon.awssdk.services.sqs.SqsAsyncClient sqsAsyncClient)	Set the SqsAsyncClient instance.

Methods inherited from class java.lang.Object

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

Constructor Details

SqsMessageConversionContext

public SqsMessageConversionContext()

Method Details

setQueueAttributes

public void setQueueAttributes(QueueAttributes queueAttributes)

Description copied from interface: QueueAttributesAware

Set the QueueAttributes instance.

Specified by:

setQueueAttributes in interface QueueAttributesAware

Parameters:

queueAttributes - the instance.

setSqsAsyncClient

public void setSqsAsyncClient(software.amazon.awssdk.services.sqs.SqsAsyncClient sqsAsyncClient)

Description copied from interface: SqsAsyncClientAware

Set the SqsAsyncClient instance.

Specified by:

setSqsAsyncClient in interface SqsAsyncClientAware

Parameters:

sqsAsyncClient - the instance.

setAcknowledgementCallback

public void setAcknowledgementCallback(AcknowledgementCallback<?> acknowledgementCallback)

Specified by:

setAcknowledgementCallback in interface AcknowledgementAwareMessageConversionContext

setPayloadClass

public void setPayloadClass(Class<?> payloadClass)

getSqsAsyncClient

@Nullable
public software.amazon.awssdk.services.sqs.SqsAsyncClient getSqsAsyncClient()

getQueueAttributes

@Nullable
public QueueAttributes getQueueAttributes()

getAcknowledgementCallback

@Nullable
public AcknowledgementCallback<?> getAcknowledgementCallback()

Specified by:

getAcknowledgementCallback in interface AcknowledgementAwareMessageConversionContext

getPayloadClass

@Nullable
public Class<?> getPayloadClass()

Description copied from interface: MessageConversionContext

An optional parameter with the payload class to be used by the conversion process.

Specified by:

getPayloadClass in interface MessageConversionContext

Returns:

the payload class.