Package overit.geocall.aws.event.consumer

Class SQSReceivedMessageBuilder

java.lang.Object

overit.geocall.aws.event.consumer.SQSReceivedMessageBuilder

All Implemented Interfaces:

BiFunction<software.amazon.awssdk.services.sqs.model.Message,String,ReceivedMessage>

@Service
@Qualifier("SQS")
public class SQSReceivedMessageBuilder
extends Object
implements BiFunction<software.amazon.awssdk.services.sqs.model.Message,String,ReceivedMessage>

class used to convert a Message, received from the queue on SQS, into ReceivedMessage. The converting is done using MessageContextBuilder to create the MessageContext and via SQSMessageMetadataExtractor to retrieve the metadata from the message

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SQS_RECEIVE_MESSAGE_BUILDER

Constructor Summary

Constructors

Constructor	Description
SQSReceivedMessageBuilder()

Method Summary

Modifier and Type	Method	Description
ReceivedMessage	apply(software.amazon.awssdk.services.sqs.model.Message message, String queue)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.BiFunction

andThen

Field Details

SQS_RECEIVE_MESSAGE_BUILDER

public static final String SQS_RECEIVE_MESSAGE_BUILDER

See Also:

• Constant Field Values

Constructor Details

SQSReceivedMessageBuilder

public SQSReceivedMessageBuilder()

Method Details

apply

public ReceivedMessage apply(software.amazon.awssdk.services.sqs.model.Message message,
 String queue)

Specified by:

apply in interface BiFunction<software.amazon.awssdk.services.sqs.model.Message,String,ReceivedMessage>