インターフェース AmqpTemplate
- 既知のすべてのサブインターフェース:
RabbitOperations
- すべての既知の実装クラス:
BatchingRabbitTemplate、RabbitTemplate、TestRabbitTemplate
public interface AmqpTemplateAMQP 操作の基本セットを指定します。同期送信および受信メソッドを提供します。convertAndSend(Object)およびreceiveAndConvert()メソッドを使用すると、POJO オブジェクトを送受信できます。実装は、AMQP byte[] ペイロード型との間の変換を実行するために、MessageConverterのインスタンスに委譲することが期待されています。- 作成者:
- Mark Pollack, Mark Fisher, Artem Bilan, Ernest Sadykov, Gary Russell
方法の概要
すべてのメソッド インスタンスメソッド 抽象メソッド 修飾子と型 メソッド 説明 voidconvertAndSend(ObjectSE message)Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。voidconvertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor)Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。voidconvertAndSend(StringSE routingKey, ObjectSE message)Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。voidconvertAndSend(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor)Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。voidconvertAndSend(StringSE exchange, StringSE routingKey, ObjectSE message)Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。voidconvertAndSend(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor)Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。ObjectSEconvertSendAndReceive(ObjectSE message)変換を伴う基本的な RPC パターン。ObjectSEconvertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor)変換を伴う基本的な RPC パターン。ObjectSEconvertSendAndReceive(StringSE routingKey, ObjectSE message)変換を伴う基本的な RPC パターン。ObjectSEconvertSendAndReceive(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor)変換を伴う基本的な RPC パターン。ObjectSEconvertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message)変換を伴う基本的な RPC パターン。ObjectSEconvertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor)変換を伴う基本的な RPC パターン。<T> TconvertSendAndReceiveAsType(ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)変換を伴う基本的な RPC パターン。<T> TconvertSendAndReceiveAsType(ObjectSE message, ParameterizedTypeReference<T> responseType)変換を伴う基本的な RPC パターン。<T> TconvertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)変換を伴う基本的な RPC パターン。<T> TconvertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType)変換を伴う基本的な RPC パターン。<T> TconvertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)変換を伴う基本的な RPC パターン。<T> TconvertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType)変換を伴う基本的な RPC パターン。Messagereceive()デフォルトキューからのメッセージがある場合は、メッセージを受信します。Messagereceive(long timeoutMillis)デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。Messagereceive(StringSE queueName)特定のキューからのメッセージがある場合、メッセージを受信します。Messagereceive(StringSE queueName, long timeoutMillis)特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。ObjectSEreceiveAndConvert()デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。ObjectSEreceiveAndConvert(long timeoutMillis)デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。<T> TreceiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type)デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。ObjectSEreceiveAndConvert(StringSE queueName)特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。ObjectSEreceiveAndConvert(StringSE queueName, long timeoutMillis)特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> TreceiveAndConvert(StringSE queueName, long timeoutMillis, ParameterizedTypeReference<T> type)特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> TreceiveAndConvert(StringSE queueName, ParameterizedTypeReference<T> type)特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。<T> TreceiveAndConvert(ParameterizedTypeReference<T> type)デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。<R,S>
booleanreceiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback)指定されたキューからメッセージがある場合はそれを受信し、指定されたReceiveAndReplyCallbackを呼び出して、callbackが応答メッセージを返した場合は、MessagePropertiesからreplyToAddressに、またはデフォルトの交換とデフォルトの routingKey に応答メッセージを送信します。<R,S>
booleanreceiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback, StringSE replyExchange, StringSE replyRoutingKey)提供されたキューからメッセージがある場合はメッセージを受信し、提供されたReceiveAndReplyCallbackを呼び出し、callbackがメッセージを返す場合は、提供されたexchangeおよびroutingKeyに応答メッセージを送信します。<R,S>
booleanreceiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)指定されたキューからメッセージがあれば受信し、指定されたReceiveAndReplyCallbackを呼び出し、callbackがメッセージを返す場合は、応答メッセージをReplyToAddressCallbackの結果からreplyToAddressに送信します。<R,S>
booleanreceiveAndReply(ReceiveAndReplyCallback<R,S> callback)デフォルトキューからメッセージがある場合はそれを受信し、提供されたReceiveAndReplyCallbackを呼び出して、callbackが応答メッセージを返した場合は、MessagePropertiesからreplyToAddressに、またはデフォルト交換とデフォルト routingKey に応答メッセージを送信します。<R,S>
booleanreceiveAndReply(ReceiveAndReplyCallback<R,S> callback, StringSE replyExchange, StringSE replyRoutingKey)デフォルトキューからメッセージがある場合はメッセージを受信し、提供されたReceiveAndReplyCallbackを呼び出し、callbackがメッセージを返す場合は、提供されたexchangeおよびroutingKeyに応答メッセージを送信します。<R,S>
booleanreceiveAndReply(ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)デフォルトのキューからメッセージがあれば受信し、提供されたReceiveAndReplyCallbackを呼び出し、callbackがメッセージを返す場合は、応答メッセージをReplyToAddressCallbackの結果からreplyToAddressに送信します。voidsend(StringSE exchange, StringSE routingKey, Message message)特定のルーティングキーを使用して、特定の交換にメッセージを送信します。voidsend(StringSE routingKey, Message message)特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。voidsend(Message message)デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。MessagesendAndReceive(StringSE exchange, StringSE routingKey, Message message)基本的な RPC パターン。MessagesendAndReceive(StringSE routingKey, Message message)基本的な RPC パターン。MessagesendAndReceive(Message message)基本的な RPC パターン。
メソッドの詳細
send
void send(Message message) throws AmqpException
デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。- パラメーター:
message- 送信するメッセージ- 例外:
AmqpException- 問題がある場合
send
void send(StringSE routingKey, Message message) throws AmqpException
特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。- パラメーター:
routingKey- ルーティングキーmessage- 送信するメッセージ- 例外:
AmqpException- 問題がある場合
send
void send(StringSE exchange, StringSE routingKey, Message message) throws AmqpException
特定のルーティングキーを使用して、特定の交換にメッセージを送信します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージ- 例外:
AmqpException- 問題がある場合
convertAndSend
void convertAndSend(ObjectSE message) throws AmqpException
Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。- パラメーター:
message- 送信するメッセージ- 例外:
AmqpException- 問題がある場合
convertAndSend
void convertAndSend(StringSE routingKey, ObjectSE message) throws AmqpException
Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。- パラメーター:
routingKey- ルーティングキーmessage- 送信するメッセージ- 例外:
AmqpException- 問題がある場合
convertAndSend
void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE message) throws AmqpException
Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージ- 例外:
AmqpException- 問題がある場合
convertAndSend
void convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException
Java オブジェクトを AmqpMessageに変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。- パラメーター:
message- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサー- 例外:
AmqpException- 問題がある場合
convertAndSend
void convertAndSend(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException
Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。- パラメーター:
routingKey- ルーティングキーmessage- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサー- 例外:
AmqpException- 問題がある場合
convertAndSend
void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException
Java オブジェクトを AmqpMessageに変換し、特定のルーティングキーを使用して特定の取引所に送信します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサー- 例外:
AmqpException- 問題がある場合
receive
@Nullable Message receive() throws AmqpException
デフォルトキューからのメッセージがある場合は、メッセージを受信します。おそらく null 値で、すぐに戻ります。- 戻り値:
- 待っているメッセージがない場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合
receive
@Nullable Message receive(StringSE queueName) throws AmqpException
特定のキューからのメッセージがある場合、メッセージを受信します。おそらく null 値で、すぐに戻ります。- パラメーター:
queueName- ポーリングするキューの名前- 戻り値:
- 待っているメッセージがない場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合
receive
@Nullable Message receive(long timeoutMillis) throws AmqpException
デフォルトのキューからメッセージを受信し、メッセージが利用可能になるまで必要に応じて指定された待機時間まで待機します。- パラメーター:
timeoutMillis- あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐにnullを返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。- 戻り値:
- 期限が切れた場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合- 導入:
- 1.6
receive
@Nullable Message receive(StringSE queueName, long timeoutMillis) throws AmqpException
特定のキューからメッセージを受信し、メッセージが使用可能になるまで必要に応じて指定された待機時間まで待機します。- パラメーター:
queueName- 受信するキューtimeoutMillis- あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐにnullを返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。- 戻り値:
- 期限が切れた場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合- 導入:
- 1.6
receiveAndConvert
@Nullable ObjectSE receiveAndConvert() throws AmqpException
デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。- 戻り値:
- 待っているメッセージがない場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合
receiveAndConvert
@Nullable ObjectSE receiveAndConvert(StringSE queueName) throws AmqpException
特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。- パラメーター:
queueName- ポーリングするキューの名前- 戻り値:
- 待っているメッセージがない場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合
receiveAndConvert
@Nullable ObjectSE receiveAndConvert(long timeoutMillis) throws AmqpException
デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。- パラメーター:
timeoutMillis- あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐにnullを返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。- 戻り値:
- 期限が切れた場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合- 導入:
- 1.6
receiveAndConvert
@Nullable ObjectSE receiveAndConvert(StringSE queueName, long timeoutMillis) throws AmqpException
特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。- パラメーター:
queueName- ポーリングするキューの名前timeoutMillis- あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐにnullを返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。- 戻り値:
- 期限が切れた場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合- 導入:
- 1.6
receiveAndConvert
@Nullable <T> T receiveAndConvert(ParameterizedTypeReference<T> type) throws AmqpException
デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
type- 変換する型。- 戻り値:
- メッセージ、または待機していない場合は null。
- 例外:
AmqpException- 問題がある場合。- 導入:
- 2.0
receiveAndConvert
@Nullable <T> T receiveAndConvert(StringSE queueName, ParameterizedTypeReference<T> type) throws AmqpException
特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
queueName- ポーリングするキューの名前type- 変換する型。- 戻り値:
- 待っているメッセージがない場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合- 導入:
- 2.0
receiveAndConvert
@Nullable <T> T receiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type) throws AmqpException
デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
timeoutMillis- あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐにnullを返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。type- 変換する型。- 戻り値:
- 期限が切れた場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合- 導入:
- 2.0
receiveAndConvert
@Nullable <T> T receiveAndConvert(StringSE queueName, long timeoutMillis, ParameterizedTypeReference<T> type) throws AmqpException
特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
queueName- ポーリングするキューの名前timeoutMillis- あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐにnullを返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。type- 変換する型。- 戻り値:
- 期限が切れた場合はメッセージまたは null
- 例外:
AmqpException- 問題がある場合- 導入:
- 2.0
receiveAndReply
<R,S> boolean receiveAndReply(ReceiveAndReplyCallback<R,S> callback) throws AmqpException
デフォルトキューからメッセージがある場合はそれを受信し、提供されたReceiveAndReplyCallbackを呼び出して、callbackが応答メッセージを返した場合は、MessagePropertiesからreplyToAddressに、またはデフォルト交換とデフォルト routingKey に応答メッセージを送信します。- 型パラメーター:
R-Messageからの変換後のリクエストの型。S- レスポンスの型。- パラメーター:
callback- 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供のReceiveAndReplyCallback実装。- 戻り値:
true、メッセージが受信された場合- 例外:
AmqpException- 問題がある場合
receiveAndReply
<R,S> boolean receiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback) throws AmqpException
指定されたキューからメッセージがある場合はそれを受信し、指定されたReceiveAndReplyCallbackを呼び出して、callbackが応答メッセージを返した場合は、MessagePropertiesからreplyToAddressに、またはデフォルトの交換とデフォルトの routingKey に応答メッセージを送信します。- 型パラメーター:
R-Messageからの変換後のリクエストの型。S- レスポンスの型。- パラメーター:
queueName- メッセージを受信するキュー名。callback- 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供のReceiveAndReplyCallback実装。- 戻り値:
true、メッセージが受信された場合。- 例外:
AmqpException- 問題がある場合。
receiveAndReply
<R,S> boolean receiveAndReply(ReceiveAndReplyCallback<R,S> callback, StringSE replyExchange, StringSE replyRoutingKey) throws AmqpException
デフォルトキューからメッセージがある場合はメッセージを受信し、提供されたReceiveAndReplyCallbackを呼び出し、callbackがメッセージを返す場合は、提供されたexchangeおよびroutingKeyに応答メッセージを送信します。- 型パラメーター:
R-Messageからの変換後のリクエストの型。S- レスポンスの型。- パラメーター:
callback- 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供のReceiveAndReplyCallback実装。replyExchange- 返信メッセージを送信する交換名。replyRoutingKey- 応答メッセージを送信するためのルーティングキー。- 戻り値:
true、メッセージが受信された場合。- 例外:
AmqpException- 問題がある場合。
receiveAndReply
<R,S> boolean receiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback, StringSE replyExchange, StringSE replyRoutingKey) throws AmqpException
提供されたキューからメッセージがある場合はメッセージを受信し、提供されたReceiveAndReplyCallbackを呼び出し、callbackがメッセージを返す場合は、提供されたexchangeおよびroutingKeyに応答メッセージを送信します。- 型パラメーター:
R-Messageからの変換後のリクエストの型。S- レスポンスの型。- パラメーター:
queueName- メッセージを受信するキュー名。callback- 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供のReceiveAndReplyCallback実装。replyExchange- 返信メッセージを送信する交換名。replyRoutingKey- 応答メッセージを送信するためのルーティングキー。- 戻り値:
true、メッセージが受信された場合- 例外:
AmqpException- 問題がある場合
receiveAndReply
<R,S> boolean receiveAndReply(ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback) throws AmqpException
デフォルトのキューからメッセージがあれば受信し、提供されたReceiveAndReplyCallbackを呼び出し、callbackがメッセージを返す場合は、応答メッセージをReplyToAddressCallbackの結果からreplyToAddressに送信します。- 型パラメーター:
R-Messageからの変換後のリクエストの型。S- レスポンスの型。- パラメーター:
callback- 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供のReceiveAndReplyCallback実装。replyToAddressCallback- 実行時に replyTo アドレスを決定するコールバック。- 戻り値:
true、メッセージが受信された場合。- 例外:
AmqpException- 問題がある場合。
receiveAndReply
<R,S> boolean receiveAndReply(StringSE queueName, ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback) throws AmqpException
指定されたキューからメッセージがあれば受信し、指定されたReceiveAndReplyCallbackを呼び出し、callbackがメッセージを返す場合は、応答メッセージをReplyToAddressCallbackの結果からreplyToAddressに送信します。- 型パラメーター:
R-Messageからの変換後のリクエストの型。S- レスポンスの型。- パラメーター:
queueName- メッセージを受信するキュー名。callback- 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供のReceiveAndReplyCallback実装。replyToAddressCallback- 実行時に replyTo アドレスを決定するコールバック。- 戻り値:
true、メッセージが受信された場合- 例外:
AmqpException- 問題がある場合
sendAndReceive
@Nullable Message sendAndReceive(Message message) throws AmqpException
基本的な RPC パターン。デフォルトのルーティングキーを使用してデフォルトの交換にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
message- 送信するメッセージ- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
sendAndReceive
@Nullable Message sendAndReceive(StringSE routingKey, Message message) throws AmqpException
基本的な RPC パターン。特定のルーティングキーを使用してデフォルトの交換にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
routingKey- ルーティングキーmessage- 送信するメッセージ- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
sendAndReceive
@Nullable Message sendAndReceive(StringSE exchange, StringSE routingKey, Message message) throws AmqpException
基本的な RPC パターン。特定のルーティングキーを使用して特定の交換機にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージ- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
convertSendAndReceive
@Nullable ObjectSE convertSendAndReceive(ObjectSE message) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
message- 送信するメッセージ- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
convertSendAndReceive
@Nullable ObjectSE convertSendAndReceive(StringSE routingKey, ObjectSE message) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
routingKey- ルーティングキーmessage- 送信するメッセージ- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
convertSendAndReceive
@Nullable ObjectSE convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージ- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
convertSendAndReceive
@Nullable ObjectSE convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
message- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサー- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
convertSendAndReceive
@Nullable ObjectSE convertSendAndReceive(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
routingKey- ルーティングキーmessage- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサー- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
convertSendAndReceive
@Nullable ObjectSE convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサー- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合
convertSendAndReceiveAsType
@Nullable <T> T convertSendAndReceiveAsType(ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
message- 送信するメッセージ。responseType- 返信を変換する型。- 戻り値:
- ある場合のレスポンス。
- 例外:
AmqpException- 問題がある場合。- 導入:
- 2.0
convertSendAndReceiveAsType
@Nullable <T> T convertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
routingKey- ルーティングキーmessage- 送信するメッセージresponseType- 返信を変換する型。- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合- 導入:
- 2.0
convertSendAndReceiveAsType
@Nullable <T> T convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージresponseType- 返信を変換する型。- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合- 導入:
- 2.0
convertSendAndReceiveAsType
@Nullable <T> T convertSendAndReceiveAsType(ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
message- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサーresponseType- 返信を変換する型。- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合- 導入:
- 2.0
convertSendAndReceiveAsType
@Nullable <T> T convertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
routingKey- ルーティングキーmessage- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサーresponseType- 返信を変換する型。- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合- 導入:
- 2.0
convertSendAndReceiveAsType
@Nullable <T> T convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) throws AmqpException
変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverterが必要です。- 型パラメーター:
T- 型。- パラメーター:
exchange- 取引所の名前routingKey- ルーティングキーmessage- 送信するメッセージmessagePostProcessor- 送信前にメッセージに適用するプロセッサーresponseType- 返信を変換する型。- 戻り値:
- ある場合のレスポンス
- 例外:
AmqpException- 問題がある場合- 導入:
- 2.0