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