io.awspring.cloud.messaging.config

Class QueueMessageHandlerFactory

java.lang.Object

io.awspring.cloud.messaging.config.QueueMessageHandlerFactory

public class QueueMessageHandlerFactory
extends Object

Since:

1.0

Author:

Alain Sahli, Maciej Walkowiak, Matej Nedic

Constructor Summary

Constructors

Constructor and Description
QueueMessageHandlerFactory()

Method Summary

Modifier and Type	Method and Description
QueueMessageHandler	createQueueMessageHandler()
com.amazonaws.services.sqs.AmazonSQS	getAmazonSqs()
List<MessageConverter>	getMessageConverters()
void	setAmazonSqs(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs) Sets the AmazonSQS client that is going to be used to create a new QueueMessagingTemplate if sendToMessagingTemplate is null.
void	setArgumentResolvers(List<HandlerMethodArgumentResolver> argumentResolvers)
void	setBeanFactory(BeanFactory beanFactory) Configures a BeanFactory that should be used to resolve expressions and placeholder for SendTo annotations.
void	setMessageConverters(List<MessageConverter> messageConverters) Configures a MessageConverters that should be used to deserialize incoming message payloads and serialize messages in QueueMessagingTemplate.
void	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper) Configures an ObjectMapper that is used by default MappingJackson2MessageConverter created if no messageConverters are set.
void	setResourceIdResolver(ResourceIdResolver resourceIdResolver) This value is only used if no sendToMessagingTemplate has been set.
void	setReturnValueHandlers(List<HandlerMethodReturnValueHandler> returnValueHandlers)
void	setSendToMessagingTemplate(DestinationResolvingMessageSendingOperations<?> sendToMessagingTemplate) Configures the DestinationResolvingMessageSendingOperations template used by the SendToHandlerMethodReturnValueHandler to send return values of handler methods.
void	setSqsMessageDeletionPolicy(SqsMessageDeletionPolicy sqsMessageDeletionPolicy) Configures global deletion Policy.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueMessageHandlerFactory

public QueueMessageHandlerFactory()

Method Detail

setArgumentResolvers

public void setArgumentResolvers(List<HandlerMethodArgumentResolver> argumentResolvers)

setReturnValueHandlers

public void setReturnValueHandlers(List<HandlerMethodReturnValueHandler> returnValueHandlers)

setSendToMessagingTemplate

public void setSendToMessagingTemplate(DestinationResolvingMessageSendingOperations<?> sendToMessagingTemplate)

Configures the DestinationResolvingMessageSendingOperations template used by the SendToHandlerMethodReturnValueHandler to send return values of handler methods.

Parameters:

sendToMessagingTemplate - A DestinationResolvingMessageSendingOperations template for sending return values of handler methods.

getAmazonSqs

public com.amazonaws.services.sqs.AmazonSQS getAmazonSqs()

setAmazonSqs

public void setAmazonSqs(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs)

Sets the AmazonSQS client that is going to be used to create a new QueueMessagingTemplate if sendToMessagingTemplate is null. This template is used by the SendToHandlerMethodReturnValueHandler to send the return values of handler methods annotated with SendTo.

An AmazonSQS client is only needed if sendToMessagingTemplate is null.

Parameters:

amazonSqs - The AmazonSQS client that is going to be used by the SendToHandlerMethodReturnValueHandler to send messages.

setSqsMessageDeletionPolicy

public void setSqsMessageDeletionPolicy(SqsMessageDeletionPolicy sqsMessageDeletionPolicy)

Configures global deletion Policy.

Parameters:

sqsMessageDeletionPolicy - if set it will use SqsMessageDeletionPolicy param as global default value only if SqsMessageDeletionPolicy is omitted from @SqsListener annotation. Should not be null.

setResourceIdResolver

public void setResourceIdResolver(ResourceIdResolver resourceIdResolver)

This value is only used if no sendToMessagingTemplate has been set.

Parameters:

resourceIdResolver - the resourceIdResolver to use for resolving logical to physical ids in a CloudFormation environment. This resolver will be used by the QueueMessagingTemplate created for the SendToHandlerMethodReturnValueHandler.

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

Configures a BeanFactory that should be used to resolve expressions and placeholder for SendTo annotations. If not set, then no expressions or place holders will be resolved.

Parameters:

beanFactory - - the bean factory used to resolve expressions and / or place holders

setObjectMapper

public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Configures an ObjectMapper that is used by default MappingJackson2MessageConverter created if no messageConverters are set.

Parameters:

objectMapper - - object mapper, can be null

createQueueMessageHandler

public QueueMessageHandler createQueueMessageHandler()

getMessageConverters

public List<MessageConverter> getMessageConverters()

setMessageConverters

public void setMessageConverters(List<MessageConverter> messageConverters)

Configures a MessageConverters that should be used to deserialize incoming message payloads and serialize messages in QueueMessagingTemplate. If not set, default MappingJackson2MessageConverter is used.

Parameters:

messageConverters - - the converters used for message conversion