クラス RabbitMessagingTemplate
- java.lang.ObjectSE
-
- org.springframework.messaging.core.AbstractMessageSendingTemplate<D>
-
- org.springframework.messaging.core.AbstractMessageReceivingTemplate<D>
-
- org.springframework.messaging.core.AbstractMessagingTemplate<StringSE>
-
- org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
- 実装されたすべてのインターフェース:
RabbitMessageOperations
、InitializingBean
、MessageReceivingOperations<StringSE>
、MessageRequestReplyOperations<StringSE>
、MessageSendingOperations<StringSE>
public class RabbitMessagingTemplate extends AbstractMessagingTemplate<StringSE> implements RabbitMessageOperations, InitializingBean
- 導入:
- 1.4
- 作成者:
- Stephane Nicoll, Gary Russell
フィールドサマリー
クラス org.springframework.messaging.core.AbstractMessageSendingTemplate から継承されたフィールド
CONVERSION_HINT_HEADER, logger
コンストラクターのサマリー
コンストラクター コンストラクター 説明 RabbitMessagingTemplate()
Bean プロパティで使用するコンストラクター。RabbitMessagingTemplate(RabbitTemplate rabbitTemplate)
使用するRabbitTemplate
を使用してインスタンスを作成します。
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 void
afterPropertiesSet()
protected MessagingException
convertAmqpException(RuntimeExceptionSE ex)
protected Message<?>
convertAmqpMessage(Message message)
void
convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload)
おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、メッセージとしてラップして、特定のルーティングキーを使用して特定の交換に送信します。void
convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MapSE<StringSE,ObjectSE> headers)
おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してメッセージとしてラップし、特定のルーティングキーを使用して特定の交換に送信します。void
convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MapSE<StringSE,ObjectSE> headers, MessagePostProcessor postProcessor)
おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。void
convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MessagePostProcessor postProcessor)
おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、それをメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。<T> T
convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass)
おそらくMessageConverter
を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、特定のルーティングキーを使用して特定の交換にMessage
として送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。<T> T
convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass, MessagePostProcessor requestPostProcessor)
おそらくMessageConverter
を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたポストプロセッサーを適用し、結果のMessage
を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。<T> T
convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass)
おそらくMessageConverter
を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してMessage
として送信し、特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。<T> T
convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass, MessagePostProcessor requestPostProcessor)
おそらくMessageConverter
を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のMessage
を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して変換します。指定されたターゲットクラスの本体。protected Message<?>
doReceive(StringSE destination)
protected void
doSend(StringSE exchange, StringSE routingKey, Message<?> message)
protected void
doSend(StringSE destination, Message<?> message)
protected Message<?>
doSendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage)
protected Message<?>
doSendAndReceive(StringSE destination, Message<?> requestMessage)
MessageConverter
getAmqpMessageConverter()
RabbitTemplate
getRabbitTemplate()
Message<?>
receive()
<T> T
receiveAndConvert(ClassSE<T> targetClass)
void
send(StringSE exchange, StringSE routingKey, Message<?> message)
特定のルーティングキーを使用して、特定の交換にメッセージを送信します。Message<?>
sendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage)
特定のルーティングキーを使用して特定の交換機にリクエストメッセージを送信し、応答を待ちます。void
setAmqpMessageConverter(MessageConverter amqpMessageConverter)
void
setRabbitTemplate(RabbitTemplate rabbitTemplate)
使用するRabbitTemplate
を設定します。void
setUseTemplateDefaultReceiveQueue(boolean useTemplateDefaultReceiveQueue)
true の場合、このテンプレートで構成されたdefaultDestination
の代わりに、基になるRabbitTemplate
の defaultReceiveQueue プロパティ (構成されている場合) を受信専用メソッドに使用します。クラス org.springframework.messaging.core.AbstractMessagingTemplate から継承されたメソッド
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive, sendAndReceive
クラス org.springframework.messaging.core.AbstractMessageReceivingTemplate から継承されたメソッド
doConvert, receive, receiveAndConvert
クラス org.springframework.messaging.core.AbstractMessageSendingTemplate から継承されたメソッド
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, doConvert, getDefaultDestination, getMessageConverter, getRequiredDefaultDestination, processHeadersToSend, send, send, setDefaultDestination, setMessageConverter
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.messaging.core.MessageReceivingOperations から継承されたメソッド
receive, receiveAndConvert
インターフェース org.springframework.messaging.core.MessageRequestReplyOperations から継承されたメソッド
convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, sendAndReceive, sendAndReceive
インターフェース org.springframework.messaging.core.MessageSendingOperations から継承されたメソッド
convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, send, send
コンストラクターの詳細
RabbitMessagingTemplate
public RabbitMessagingTemplate()
Bean プロパティで使用するコンストラクター。setRabbitTemplate(org.springframework.amqp.rabbit.core.RabbitTemplate)
を呼び出す必要があります。
RabbitMessagingTemplate
public RabbitMessagingTemplate(RabbitTemplate rabbitTemplate)
使用するRabbitTemplate
を使用してインスタンスを作成します。- パラメーター:
rabbitTemplate
- テンプレート。
メソッドの詳細
setRabbitTemplate
public void setRabbitTemplate(RabbitTemplate rabbitTemplate)
使用するRabbitTemplate
を設定します。- パラメーター:
rabbitTemplate
- テンプレート。
getRabbitTemplate
public RabbitTemplate getRabbitTemplate()
- 戻り値:
- 構成された
RabbitTemplate
setAmqpMessageConverter
public void setAmqpMessageConverter(MessageConverter amqpMessageConverter)
Message
をメッセージングからMessage
へ、またはMessage
から変換するために使用するMessageConverter
を設定します。デフォルトでは、MessagingMessageConverter
は、提供されているRabbitTemplate
のメッセージコンバーター (デフォルトではSimpleMessageConverter
) を使用して定義され、メッセージのペイロードを変換します。より高度なシナリオでは、
MessagingMessageConverter
を異なるpayload converter
で構成することを検討してください。- パラメーター:
amqpMessageConverter
- メッセージコンバーター。- 関連事項:
MessagingMessageConverter
getAmqpMessageConverter
public MessageConverter getAmqpMessageConverter()
- 戻り値:
Message
をメッセージングからMessage
に変換するために使用するMessageConverter
。
setUseTemplateDefaultReceiveQueue
public void setUseTemplateDefaultReceiveQueue(boolean useTemplateDefaultReceiveQueue)
true の場合、このテンプレートで構成されたdefaultDestination
の代わりに、基になるRabbitTemplate
の defaultReceiveQueue プロパティ (構成されている場合) を受信専用メソッドに使用します。代わりにテンプレートのキューを使用するには、これを true に設定します。デフォルトは false ですが、将来のリリースでは true になる予定です。- パラメーター:
useTemplateDefaultReceiveQueue
- テンプレートのキューを使用する場合は true。- 導入:
- 2.2.22
afterPropertiesSet
public void afterPropertiesSet()
- 次で指定:
- インターフェース
InitializingBean
のafterPropertiesSet
send
public void send(StringSE exchange, StringSE routingKey, Message<?> message) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
特定のルーティングキーを使用して、特定の交換にメッセージを送信します。- 次で指定:
- インターフェース
RabbitMessageOperations
のsend
- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーmessage
- 送信するメッセージ- 例外:
MessagingException
- メッセージングの例外。
convertAndSend
public void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、メッセージとしてラップして、特定のルーティングキーを使用して特定の交換に送信します。- 次で指定:
- インターフェース
RabbitMessageOperations
のconvertAndSend
- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーpayload
- ペイロードとして使用するオブジェクト- 例外:
MessagingException
- メッセージングの例外。
convertAndSend
public void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, @Nullable MapSE<StringSE,ObjectSE> headers) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してメッセージとしてラップし、特定のルーティングキーを使用して特定の交換に送信します。- 次で指定:
- インターフェース
RabbitMessageOperations
のconvertAndSend
- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーpayload
- ペイロードとして使用するオブジェクトheaders
- 送信するメッセージのヘッダー- 例外:
MessagingException
- メッセージングの例外。
convertAndSend
public void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, @Nullable MessagePostProcessor postProcessor) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、それをメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。- 次で指定:
- インターフェース
RabbitMessageOperations
のconvertAndSend
- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーpayload
- ペイロードとして使用するオブジェクトpostProcessor
- メッセージに適用するポストプロセッサー- 例外:
MessagingException
- メッセージングの例外。
convertAndSend
public void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, @Nullable MapSE<StringSE,ObjectSE> headers, @Nullable MessagePostProcessor postProcessor) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。- 次で指定:
- インターフェース
RabbitMessageOperations
のconvertAndSend
- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーpayload
- ペイロードとして使用するオブジェクトheaders
- 送信するメッセージのヘッダーpostProcessor
- メッセージに適用するポストプロセッサー- 例外:
MessagingException
- メッセージングの例外。
sendAndReceive
@Nullable public Message<?> sendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
特定のルーティングキーを使用して特定の交換機にリクエストメッセージを送信し、応答を待ちます。- 次で指定:
- インターフェース
RabbitMessageOperations
のsendAndReceive
- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーrequestMessage
- 送信するメッセージ- 戻り値:
- 応答。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null
- 例外:
MessagingException
- メッセージングの例外。
convertSendAndReceive
@Nullable public <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
おそらくMessageConverter
を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、特定のルーティングキーを使用して特定の交換にMessage
として送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。- 次で指定:
- インターフェース
RabbitMessageOperations
のconvertSendAndReceive
- 型パラメーター:
T
- 戻りの型- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーrequest
- 送信するリクエストメッセージのペイロードtargetClass
- 応答のペイロードを変換するターゲット型- 戻り値:
- 応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null
- 例外:
MessagingException
- メッセージングの例外。
convertSendAndReceive
@Nullable public <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, @Nullable MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
おそらくMessageConverter
を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してMessage
として送信し、特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。- 次で指定:
- インターフェース
RabbitMessageOperations
のconvertSendAndReceive
- 型パラメーター:
T
- 戻りの型- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーrequest
- 送信するリクエストメッセージのペイロードheaders
- 送信するリクエストメッセージのヘッダーtargetClass
- 応答のペイロードを変換するターゲット型- 戻り値:
- 応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null
- 例外:
MessagingException
- メッセージングの例外。
convertSendAndReceive
@Nullable public <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass, @Nullable MessagePostProcessor requestPostProcessor) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
おそらくMessageConverter
を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたポストプロセッサーを適用し、結果のMessage
を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。- 次で指定:
- インターフェース
RabbitMessageOperations
のconvertSendAndReceive
- 型パラメーター:
T
- 戻りの型- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーrequest
- 送信するリクエストメッセージのペイロードtargetClass
- 応答のペイロードを変換するターゲット型requestPostProcessor
- リクエストメッセージに適用するポストプロセス- 戻り値:
- 応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null
- 例外:
MessagingException
- メッセージングの例外。
convertSendAndReceive
@Nullable public <T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, @Nullable MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass, @Nullable MessagePostProcessor requestPostProcessor) throws MessagingException
インターフェースからコピーされた説明:RabbitMessageOperations
おそらくMessageConverter
を使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のMessage
を特定のルーティングキーを使用して特定の交換に送信し、応答を受信して変換します。指定されたターゲットクラスの本体。- 次で指定:
- インターフェース
RabbitMessageOperations
のconvertSendAndReceive
- 型パラメーター:
T
- 戻りの型- パラメーター:
exchange
- 取引所の名前routingKey
- ルーティングキーrequest
- 送信するリクエストメッセージのペイロードheaders
- 送信するメッセージのヘッダーtargetClass
- 応答のペイロードを変換するターゲット型requestPostProcessor
- リクエストメッセージに適用するポストプロセス- 戻り値:
- 応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null
- 例外:
MessagingException
- メッセージングの例外。
doSend
protected void doSend(StringSE destination, Message<?> message)
- 次で指定:
- クラス
AbstractMessageSendingTemplate<StringSE>
のdoSend
receive
@Nullable public Message<?> receive()
- 次で指定:
- インターフェース
MessageReceivingOperations<StringSE>
のreceive
- オーバーライド:
- クラス
AbstractMessageReceivingTemplate<StringSE>
のreceive
receiveAndConvert
@Nullable public <T> T receiveAndConvert(ClassSE<T> targetClass)
- 次で指定:
- インターフェース
MessageReceivingOperations<StringSE>
のreceiveAndConvert
- オーバーライド:
- クラス
AbstractMessageReceivingTemplate<StringSE>
のreceiveAndConvert
doReceive
protected Message<?> doReceive(StringSE destination)
- 次で指定:
- クラス
AbstractMessageReceivingTemplate<StringSE>
のdoReceive
doSendAndReceive
@Nullable protected Message<?> doSendAndReceive(StringSE destination, Message<?> requestMessage)
- 次で指定:
- クラス
AbstractMessagingTemplate<StringSE>
のdoSendAndReceive
doSendAndReceive
@Nullable protected Message<?> doSendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage)
convertAmqpException
protected MessagingException convertAmqpException(RuntimeExceptionSE ex)