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

Class SqsHeaderMapper

java.lang.Object

io.awspring.cloud.sqs.support.converter.SqsHeaderMapper

All Implemented Interfaces:

ContextAwareHeaderMapper<software.amazon.awssdk.services.sqs.model.Message>, HeaderMapper<software.amazon.awssdk.services.sqs.model.Message>

public class SqsHeaderMapper
extends Object
implements ContextAwareHeaderMapper<software.amazon.awssdk.services.sqs.model.Message>

A HeaderMapper implementation for SQS Messages. Enables creating additional SQS related headers from a SqsMessageConversionContext.

Since:

3.0

Author:

Tomaz Fernandes, Alain Sahli, Maciej Walkowiak

See Also:

• SqsMessagingMessageConverter

Constructor Summary

Constructors

Constructor	Description
SqsHeaderMapper()

Method Summary

Modifier and Type	Method	Description
MessageHeaders	createContextHeaders(software.amazon.awssdk.services.sqs.model.Message source, MessageConversionContext context)
software.amazon.awssdk.services.sqs.model.Message	fromHeaders(MessageHeaders headers)	Map the provided MessageHeaders into the returning message type.
void	setAdditionalHeadersFunction(BiFunction<software.amazon.awssdk.services.sqs.model.Message,MessageHeaderAccessor,MessageHeaders> headerFunction)
MessageHeaders	toHeaders(software.amazon.awssdk.services.sqs.model.Message source)	Map the provided source into a MessageHeaders instance.

Methods inherited from class java.lang.Object

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

Constructor Details

SqsHeaderMapper

public SqsHeaderMapper()

Method Details

setAdditionalHeadersFunction

public void setAdditionalHeadersFunction(BiFunction<software.amazon.awssdk.services.sqs.model.Message,MessageHeaderAccessor,MessageHeaders> headerFunction)

fromHeaders

public software.amazon.awssdk.services.sqs.model.Message fromHeaders(MessageHeaders headers)

Description copied from interface: HeaderMapper

Map the provided MessageHeaders into the returning message type.

Specified by:

fromHeaders in interface HeaderMapper<software.amazon.awssdk.services.sqs.model.Message>

Parameters:

headers - the headers from which to map.

Returns:

the mapped message instance.

toHeaders

public MessageHeaders toHeaders(software.amazon.awssdk.services.sqs.model.Message source)

Description copied from interface: HeaderMapper

Map the provided source into a MessageHeaders instance.

Specified by:

toHeaders in interface HeaderMapper<software.amazon.awssdk.services.sqs.model.Message>

Parameters:

source - the source from which to map.

Returns:

the mapped MessageHeaders instance.

createContextHeaders

public MessageHeaders createContextHeaders(software.amazon.awssdk.services.sqs.model.Message source,
 MessageConversionContext context)

Specified by:

createContextHeaders in interface ContextAwareHeaderMapper<software.amazon.awssdk.services.sqs.model.Message>