io.awspring.cloud.messaging.core

Class QueueMessagingTemplate

java.lang.Object

org.springframework.messaging.core.AbstractMessageSendingTemplate<D>

io.awspring.cloud.messaging.core.support.AbstractMessageChannelMessagingSendingTemplate<QueueMessageChannel>

io.awspring.cloud.messaging.core.QueueMessagingTemplate

All Implemented Interfaces:

DestinationResolvingMessageReceivingOperations<QueueMessageChannel>, DestinationResolvingMessageSendingOperations<QueueMessageChannel>, MessageReceivingOperations<QueueMessageChannel>, MessageSendingOperations<QueueMessageChannel>

public class QueueMessagingTemplate
extends AbstractMessageChannelMessagingSendingTemplate<QueueMessageChannel>
implements DestinationResolvingMessageReceivingOperations<QueueMessageChannel>

IMPORTANT: For the message conversion this class always tries to first use the StringMessageConverter as it fits the underlying message channel type. If a message converter is set through the constructor then it is added to a composite converter already containing the StringMessageConverter. If AbstractMessageSendingTemplate.setMessageConverter(MessageConverter) is used, then the CompositeMessageConverter containing the StringMessageConverter will not be used anymore and the String payloads are also going to be converted with the set converter.

Since:

1.0

Author:

Agim Emruli, Alain Sahli

Field Summary

Fields inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate

CONVERSION_HINT_HEADER, logger

Constructor Summary

Constructors

Constructor and Description
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs)
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, DestinationResolver<String> destinationResolver, MessageConverter messageConverter) Initializes the messaging template by configuring the destination resolver as well as the message converter.
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, DestinationResolver<String> destinationResolver, MessageConverter messageConverter, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, ResourceIdResolver resourceIdResolver)
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, ResourceIdResolver resourceIdResolver, MessageConverter messageConverter) Initializes the messaging template by configuring the resource Id resolver as well as the message converter.
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, ResourceIdResolver resourceIdResolver, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method and Description
Message<?>	receive()
Message<?>	receive(QueueMessageChannel destination)
Message<?>	receive(String destinationName)
<T> T	receiveAndConvert(Class<T> targetClass)
<T> T	receiveAndConvert(QueueMessageChannel destination, Class<T> targetClass)
<T> T	receiveAndConvert(String destinationName, Class<T> targetClass)
protected QueueMessageChannel	resolveMessageChannel(String physicalResourceIdentifier)

Methods inherited from class io.awspring.cloud.messaging.core.support.AbstractMessageChannelMessagingSendingTemplate

convertAndSend, convertAndSend, convertAndSend, convertAndSend, doSend, initMessageConverter, initMessageConverter, resolveMessageChannelByLogicalName, send, setDefaultDestinationName

Methods inherited from class org.springframework.messaging.core.AbstractMessageSendingTemplate

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.messaging.core.MessageSendingOperations

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, send

Constructor Detail

QueueMessagingTemplate

public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs)

QueueMessagingTemplate

public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
                              ResourceIdResolver resourceIdResolver)

QueueMessagingTemplate

public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
                              ResourceIdResolver resourceIdResolver,
                              MessageConverter messageConverter)

Initializes the messaging template by configuring the resource Id resolver as well as the message converter. Uses the DynamicQueueUrlDestinationResolver with the default configuration to resolve destination names.

Parameters:

amazonSqs - The AmazonSQS client, cannot be null.

resourceIdResolver - The ResourceIdResolver to be used for resolving logical queue names.

messageConverter - A MessageConverter that is going to be added to the composite converter.

QueueMessagingTemplate

public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
                              ResourceIdResolver resourceIdResolver,
                              com.fasterxml.jackson.databind.ObjectMapper objectMapper)

QueueMessagingTemplate

public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
                              DestinationResolver<String> destinationResolver,
                              MessageConverter messageConverter)

Initializes the messaging template by configuring the destination resolver as well as the message converter. Uses the DynamicQueueUrlDestinationResolver with the default configuration to resolve destination names.

Parameters:

amazonSqs - The AmazonSQS client, cannot be null.

destinationResolver - A destination resolver implementation to resolve queue names into queue urls. The destination resolver will be wrapped into a CachingDestinationResolverProxy to avoid duplicate queue url resolutions.

messageConverter - A MessageConverter that is going to be added to the composite converter.

QueueMessagingTemplate

public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs,
                              DestinationResolver<String> destinationResolver,
                              MessageConverter messageConverter,
                              com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Detail

resolveMessageChannel

protected QueueMessageChannel resolveMessageChannel(String physicalResourceIdentifier)

Specified by:

resolveMessageChannel in class AbstractMessageChannelMessagingSendingTemplate<QueueMessageChannel>

receive

public Message<?> receive()
                   throws MessagingException

Specified by:

receive in interface MessageReceivingOperations<QueueMessageChannel>

Throws:

MessagingException

receive

public Message<?> receive(QueueMessageChannel destination)
                   throws MessagingException

Specified by:

receive in interface MessageReceivingOperations<QueueMessageChannel>

Throws:

MessagingException

receiveAndConvert

public <T> T receiveAndConvert(Class<T> targetClass)
                        throws MessagingException

Specified by:

receiveAndConvert in interface MessageReceivingOperations<QueueMessageChannel>

Throws:

MessagingException

receiveAndConvert

public <T> T receiveAndConvert(QueueMessageChannel destination,
                               Class<T> targetClass)
                        throws MessagingException

Specified by:

receiveAndConvert in interface MessageReceivingOperations<QueueMessageChannel>

Throws:

MessagingException

receive

public Message<?> receive(String destinationName)
                   throws MessagingException

Specified by:

receive in interface DestinationResolvingMessageReceivingOperations<QueueMessageChannel>

Throws:

MessagingException

receiveAndConvert

public <T> T receiveAndConvert(String destinationName,
                               Class<T> targetClass)
                        throws MessagingException

Specified by:

receiveAndConvert in interface DestinationResolvingMessageReceivingOperations<QueueMessageChannel>

Throws:

MessagingException