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()
QueueAttributes	getQueueAttributes()
software.amazon.awssdk.services.sqs.SqsAsyncClient	getSqsAsyncClient()
void	setAcknowledgementCallback(AcknowledgementCallback<?> acknowledgementCallback)
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

getSqsAsyncClient

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

getQueueAttributes

public QueueAttributes getQueueAttributes()

getAcknowledgementCallback

public AcknowledgementCallback<?> getAcknowledgementCallback()

Specified by:

getAcknowledgementCallback in interface AcknowledgementAwareMessageConversionContext