public class QueueMessagingTemplate extends AbstractMessageChannelMessagingSendingTemplate<QueueMessageChannel> implements DestinationResolvingMessageReceivingOperations<QueueMessageChannel>
StringMessageConverter
を使用しようとします。メッセージコンバーターがコンストラクターを介して設定されている場合、すでに StringMessageConverter
を含む複合コンバーターに追加されます。AbstractMessageSendingTemplate.setMessageConverter(MessageConverter)
が使用される場合、StringMessageConverter
を含む CompositeMessageConverter
は使用されなくなり、String
ペイロードもセットコンバーターで変換されます。CONVERSION_HINT_HEADER, logger
コンストラクターと説明 |
---|
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs) |
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, DestinationResolver<StringSE> destinationResolver, MessageConverter messageConverter) 宛先リゾルバーとメッセージコンバーターを構成して、メッセージングテンプレートを初期化します。 |
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, ResourceIdResolver resourceIdResolver) |
QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, ResourceIdResolver resourceIdResolver, MessageConverter messageConverter) リソース ID リゾルバーとメッセージコンバーターを構成して、メッセージングテンプレートを初期化します。 |
修飾子と型 | メソッドと説明 |
---|---|
Message<?> | receive() |
Message<?> | receive(QueueMessageChannel destination) |
Message<?> | receive(StringSE destinationName) |
<T> T | receiveAndConvert(ClassSE<T> targetClass) |
<T> T | receiveAndConvert(QueueMessageChannel destination, ClassSE<T> targetClass) |
<T> T | receiveAndConvert(StringSE destinationName, ClassSE<T> targetClass) |
protected QueueMessageChannel | resolveMessageChannel(StringSE physicalResourceIdentifier) |
convertAndSend, convertAndSend, convertAndSend, convertAndSend, doSend, initMessageConverter, resolveMessageChannelByLogicalName, send, setDefaultDestinationName
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, send
public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs)
public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, ResourceIdResolver resourceIdResolver)
public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, ResourceIdResolver resourceIdResolver, MessageConverter messageConverter)
DynamicQueueUrlDestinationResolver
を使用して、宛先名を解決します。amazonSqs
- AmazonSQS
クライアントは null
にすることはできません。resourceIdResolver
- 論理キュー名の解決に使用される ResourceIdResolver
。messageConverter
- 複合コンバーターに追加される MessageConverter
。public QueueMessagingTemplate(com.amazonaws.services.sqs.AmazonSQSAsync amazonSqs, DestinationResolver<StringSE> destinationResolver, MessageConverter messageConverter)
DynamicQueueUrlDestinationResolver
を使用して、宛先名を解決します。amazonSqs
- AmazonSQS
クライアントは null
にすることはできません。destinationResolver
- キュー名をキュー URL に解決するための宛先リゾルバーの実装。宛先リゾルバーは、キューの URL 解決の重複を避けるために、CachingDestinationResolverProxy
にラップされます。messageConverter
- 複合コンバーターに追加される MessageConverter
。protected QueueMessageChannel resolveMessageChannel(StringSE physicalResourceIdentifier)
public Message<?> receive() throws MessagingException
MessageReceivingOperations<QueueMessageChannel>
の receive
MessagingException
public Message<?> receive(QueueMessageChannel destination) throws MessagingException
MessageReceivingOperations<QueueMessageChannel>
の receive
MessagingException
public <T> T receiveAndConvert(ClassSE<T> targetClass) throws MessagingException
MessageReceivingOperations<QueueMessageChannel>
の receiveAndConvert
MessagingException
public <T> T receiveAndConvert(QueueMessageChannel destination, ClassSE<T> targetClass) throws MessagingException
MessageReceivingOperations<QueueMessageChannel>
の receiveAndConvert
MessagingException
public Message<?> receive(StringSE destinationName) throws MessagingException
DestinationResolvingMessageReceivingOperations<QueueMessageChannel>
の receive
MessagingException
public <T> T receiveAndConvert(StringSE destinationName, ClassSE<T> targetClass) throws MessagingException
Copyright © 2021 Pivotal Software, Inc.. All rights reserved.