インターフェース AmqpTemplate

メソッドの詳細

• 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 オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。

  パラメーター:

  message - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  void convertAndSend(@Nullable StringSE routingKey, ObjectSE message) throws AmqpException

  Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message) throws AmqpException

  Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。

  パラメーター:

  exchange - 取引所の名前

  routingKey - ルーティングキー

  message - 送信するメッセージ

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  void convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

  Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。

  パラメーター:

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  void convertAndSend(@Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

  Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。

  パラメーター:

  routingKey - ルーティングキー

  message - 送信するメッセージ

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー

  例外:

  AmqpException - 問題がある場合

• convertAndSend

  void convertAndSend(@Nullable StringSE exchange, @Nullable StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

  Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。

  パラメーター:

  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

  <T> @Nullable T receiveAndConvert(ParameterizedTypeReference<T> type) throws AmqpException

  デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。SmartMessageConverter が必要です。

  型パラメーター:

  T - 型。

  パラメーター:

  type - 変換する型。

  戻り値:

  メッセージ、または待機していない場合は null。

  例外:

  AmqpException - 問題がある場合。

  導入:

  2.0

• receiveAndConvert

  <T> @Nullable T receiveAndConvert(StringSE queueName, ParameterizedTypeReference<T> type) throws AmqpException

  特定のキューからのメッセージがあれば受信し、それを Java オブジェクトに変換します。おそらく null 値で、すぐに戻ります。SmartMessageConverter が必要です。

  型パラメーター:

  T - 型。

  パラメーター:

  queueName - ポーリングするキューの名前

  type - 変換する型。

  戻り値:

  待っているメッセージがない場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

  導入:

  2.0

• receiveAndConvert

  <T> @Nullable T receiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type) throws AmqpException

  デフォルトのキューからメッセージがある場合はそれを受け取り、それを Java オブジェクトに変換します。メッセージが利用可能になるまで、必要に応じて指定された待機時間まで待機します。SmartMessageConverter が必要です。

  型パラメーター:

  T - 型。

  パラメーター:

  timeoutMillis - あきらめるまでにどれだけ待つか。ゼロの値は、利用可能なメッセージがない場合、メソッドがすぐに null を返すことを意味します。負の値を指定すると、メソッドは無期限にメッセージを待ちます。

  type - 変換する型。

  戻り値:

  期限が切れた場合はメッセージまたは null

  例外:

  AmqpException - 問題がある場合

  導入:

  2.0

• receiveAndConvert

  <T> @Nullable 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 から replyTo Address に、またはデフォルト交換とデフォルト routingKey に応答メッセージを送信します。

  型パラメーター:

  R - Message からの変換後のリクエストの型。

  S - レスポンスの型。

  パラメーター:

  callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。

  戻り値:

  true、メッセージが受信された場合

  例外:

  AmqpException - 問題がある場合

• receiveAndReply

  <R,S> boolean receiveAndReply(StringSE 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, 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 の結果から replyTo Address に送信します。

  型パラメーター:

  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 の結果から replyTo Address に送信します。

  型パラメーター:

  R - Message からの変換後のリクエストの型。

  S - レスポンスの型。

  パラメーター:

  queueName - メッセージを受信するキュー名。

  callback - 受信したメッセージを処理し、応答メッセージを返すためのユーザー提供の ReceiveAndReplyCallback 実装。

  replyToAddressCallback - 実行時に replyTo アドレスを決定するコールバック。

  戻り値:

  true、メッセージが受信された場合

  例外:

  AmqpException - 問題がある場合

• sendAndReceive

  @Nullable Message sendAndReceive(Message message) throws AmqpException

  基本的な RPC パターン。デフォルトのルーティングキーを使用してデフォルトの交換にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• sendAndReceive

  @Nullable Message sendAndReceive(StringSE routingKey, Message message) throws AmqpException

  基本的な RPC パターン。特定のルーティングキーを使用してデフォルトの交換にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• sendAndReceive

  @Nullable Message sendAndReceive(StringSE exchange, StringSE routingKey, Message message) throws AmqpException

  基本的な RPC パターン。特定のルーティングキーを使用して特定の交換機にメッセージを送信し、レスポンスの受信を試みます。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  @Nullable ObjectSE convertSendAndReceive(ObjectSE message) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  @Nullable ObjectSE convertSendAndReceive(StringSE routingKey, ObjectSE message) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  @Nullable ObjectSE convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  @Nullable ObjectSE convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  @Nullable ObjectSE convertSendAndReceive(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceive

  @Nullable ObjectSE convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

• convertSendAndReceiveAsType

  <T> @Nullable T convertSendAndReceiveAsType(ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  型パラメーター:

  T - 型。

  パラメーター:

  message - 送信するメッセージ。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

  導入:

  2.0

• convertSendAndReceiveAsType

  <T> @Nullable T convertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  型パラメーター:

  T - 型。

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

  導入:

  2.0

• convertSendAndReceiveAsType

  <T> @Nullable T convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, ParameterizedTypeReference<T> responseType) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  型パラメーター:

  T - 型。

  パラメーター:

  exchange - 取引所の名前。

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

  導入:

  2.0

• convertSendAndReceiveAsType

  <T> @Nullable T convertSendAndReceiveAsType(ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  型パラメーター:

  T - 型。

  パラメーター:

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

  導入:

  2.0

• convertSendAndReceiveAsType

  <T> @Nullable T convertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType) throws AmqpException

  変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。

  型パラメーター:

  T - 型。

  パラメーター:

  routingKey - ルーティングキー。

  message - 送信するメッセージ。

  messagePostProcessor - 送信前にメッセージに適用するプロセッサー。

  responseType - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

  導入:

  2.0

• convertSendAndReceiveAsType

  <T> @Nullable 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 - 返信を変換する型。

  戻り値:

  レスポンス ; レスポンスがタイムアウトした場合は null。

  例外:

  AmqpException - 問題がある場合。

  導入:

  2.0