インターフェース RabbitMessageOperations
- すべてのスーパーインターフェース:
MessageReceivingOperations<StringSE>、MessageRequestReplyOperations<StringSE>、MessageSendingOperations<StringSE>
- すべての既知の実装クラス:
RabbitMessagingTemplate
public interface RabbitMessageOperations extends MessageSendingOperations<StringSE>, MessageReceivingOperations<StringSE>, MessageRequestReplyOperations<StringSE>
MessageSendingOperationsおよびMessageRequestReplyOperationsを AMQP 関連の操作に特化したもので、交換だけでなく、使用するルーティングキーも指定できます。- 導入:
- 1.4
- 作成者:
- Stephane Nicoll
- 関連事項:
RabbitTemplate
メソッドのサマリー
すべてのメソッド インスタンスメソッド 抽象メソッド 修飾子と型 メソッド 説明 voidconvertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload)おそらくMessageConverterを使用して、指定されたオブジェクトを直列化された形式に変換し、メッセージとしてラップして、特定のルーティングキーを使用して特定の交換に送信します。voidconvertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MapSE<StringSE,ObjectSE> headers)おそらくMessageConverterを使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してメッセージとしてラップし、特定のルーティングキーを使用して特定の交換に送信します。voidconvertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MapSE<StringSE,ObjectSE> headers, MessagePostProcessor postProcessor)おそらくMessageConverterを使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。voidconvertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MessagePostProcessor postProcessor)おそらくMessageConverterを使用して、指定されたオブジェクトを直列化された形式に変換し、それをメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。<T> TconvertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass)おそらくMessageConverterを使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、特定のルーティングキーを使用して特定の交換にMessageとして送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。<T> TconvertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass, MessagePostProcessor requestPostProcessor)おそらくMessageConverterを使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたポストプロセッサーを適用し、結果のMessageを特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。<T> TconvertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass)おそらくMessageConverterを使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してMessageとして送信し、特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。<T> TconvertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass, MessagePostProcessor requestPostProcessor)おそらくMessageConverterを使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のMessageを特定のルーティングキーを使用して特定の交換に送信し、応答を受信して変換します。指定されたターゲットクラスの本体。voidsend(StringSE exchange, StringSE routingKey, Message<?> message)特定のルーティングキーを使用して、特定の交換にメッセージを送信します。Message<?>sendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage)特定のルーティングキーを使用して特定の交換機にリクエストメッセージを送信し、応答を待ちます。インターフェース org.springframework.messaging.core.MessageReceivingOperations から継承されたメソッド
receive, receive, receiveAndConvert, 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
メソッドの詳細
send
void send(StringSE exchange, StringSE routingKey, Message<?> message) throws MessagingException
特定のルーティングキーを使用して、特定の交換にメッセージを送信します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージ- 例外:
MessagingException- メッセージングの例外。
convertAndSend
void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload) throws MessagingException
おそらくMessageConverterを使用して、指定されたオブジェクトを直列化された形式に変換し、メッセージとしてラップして、特定のルーティングキーを使用して特定の交換に送信します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーpayload- ペイロードとして使用するオブジェクト- 例外:
MessagingException- メッセージングの例外。
convertAndSend
void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MapSE<StringSE,ObjectSE> headers) throws MessagingException
おそらくMessageConverterを使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してメッセージとしてラップし、特定のルーティングキーを使用して特定の交換に送信します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーpayload- ペイロードとして使用するオブジェクトheaders- 送信するメッセージのヘッダー- 例外:
MessagingException- メッセージングの例外。
convertAndSend
void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MessagePostProcessor postProcessor) throws MessagingException
おそらくMessageConverterを使用して、指定されたオブジェクトを直列化された形式に変換し、それをメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーpayload- ペイロードとして使用するオブジェクトpostProcessor- メッセージに適用するポストプロセッサー- 例外:
MessagingException- メッセージングの例外。
convertAndSend
void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE payload, MapSE<StringSE,ObjectSE> headers, MessagePostProcessor postProcessor) throws MessagingException
おそらくMessageConverterを使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のメッセージを特定のルーティングキーを使用して特定の交換に送信します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーpayload- ペイロードとして使用するオブジェクトheaders- 送信するメッセージのヘッダーpostProcessor- メッセージに適用するポストプロセッサー- 例外:
MessagingException- メッセージングの例外。
sendAndReceive
Message<?> sendAndReceive(StringSE exchange, StringSE routingKey, Message<?> requestMessage) throws MessagingException
特定のルーティングキーを使用して特定の交換機にリクエストメッセージを送信し、応答を待ちます。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーrequestMessage- 送信するメッセージ- 戻り値:
- 応答。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null - 例外:
MessagingException- メッセージングの例外。
convertSendAndReceive
<T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass) throws MessagingException
おそらくMessageConverterを使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、特定のルーティングキーを使用して特定の交換にMessageとして送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。- 型パラメーター:
T- 戻りの型- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーrequest- 送信するリクエストメッセージのペイロードtargetClass- 応答のペイロードを変換するターゲット型- 戻り値:
- 応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null - 例外:
MessagingException- メッセージングの例外。
convertSendAndReceive
<T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass) throws MessagingException
おそらくMessageConverterを使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーを使用してMessageとして送信し、特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。- 型パラメーター:
T- 戻りの型- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーrequest- 送信するリクエストメッセージのペイロードheaders- 送信するリクエストメッセージのヘッダーtargetClass- 応答のペイロードを変換するターゲット型- 戻り値:
- 応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null - 例外:
MessagingException- メッセージングの例外。
convertSendAndReceive
<T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, ClassSE<T> targetClass, MessagePostProcessor requestPostProcessor) throws MessagingException
おそらくMessageConverterを使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたポストプロセッサーを適用し、結果のMessageを特定のルーティングキーを使用して特定の交換に送信し、応答を受信して、指定されたターゲットクラスのボディを変換します。- 型パラメーター:
T- 戻りの型- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーrequest- 送信するリクエストメッセージのペイロードtargetClass- 応答のペイロードを変換するターゲット型requestPostProcessor- リクエストメッセージに適用するポストプロセス- 戻り値:
- 応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null - 例外:
MessagingException- メッセージングの例外。
convertSendAndReceive
<T> T convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE request, MapSE<StringSE,ObjectSE> headers, ClassSE<T> targetClass, MessagePostProcessor requestPostProcessor) throws MessagingException
おそらくMessageConverterを使用して、指定されたリクエストオブジェクトを直列化された形式に変換し、指定されたヘッダーでメッセージとしてラップし、指定されたポストプロセッサーを適用し、結果のMessageを特定のルーティングキーを使用して特定の交換に送信し、応答を受信して変換します。指定されたターゲットクラスの本体。- 型パラメーター:
T- 戻りの型- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーrequest- 送信するリクエストメッセージのペイロードheaders- 送信するメッセージのヘッダーtargetClass- 応答のペイロードを変換するターゲット型requestPostProcessor- リクエストメッセージに適用するポストプロセス- 戻り値:
- 応答メッセージのペイロード。たとえば、タイムアウトのためにメッセージを受信できなかった場合は
null - 例外:
MessagingException- メッセージングの例外。