インターフェース AsyncAmqpTemplate
- すべての既知の実装クラス:
AsyncRabbitTemplate
public interface AsyncAmqpTemplate
このインターフェースを実装するクラスは、非同期の送受信操作を実行できます。- 導入:
- 2.0
- 作成者:
- Gary Russell
メソッドのサマリー
すべてのメソッド インスタンスメソッド 抽象メソッド 修飾子と型 メソッド 説明 <C> ListenableFuture<C>
convertSendAndReceive(ObjectSE object)
オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。<C> ListenableFuture<C>
convertSendAndReceive(ObjectSE object, MessagePostProcessor messagePostProcessor)
オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。<C> ListenableFuture<C>
convertSendAndReceive(StringSE routingKey, ObjectSE object)
オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。<C> ListenableFuture<C>
convertSendAndReceive(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)
オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。<C> ListenableFuture<C>
convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE object)
オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。<C> ListenableFuture<C>
convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)
MessagePostProcessor
を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。<C> ListenableFuture<C>
convertSendAndReceiveAsType(ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。<C> ListenableFuture<C>
convertSendAndReceiveAsType(ObjectSE object, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。<C> ListenableFuture<C>
convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。<C> ListenableFuture<C>
convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。<C> ListenableFuture<C>
convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
MessagePostProcessor
を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。<C> ListenableFuture<C>
convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。ListenableFuture<Message>
sendAndReceive(StringSE exchange, StringSE routingKey, Message message)
指定された交換およびルーティングキーにメッセージを送信します。ListenableFuture<Message>
sendAndReceive(StringSE routingKey, Message message)
指定されたルーティングキーを使用して、デフォルトの交換にメッセージを送信します。ListenableFuture<Message>
sendAndReceive(Message message)
デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。
メソッドの詳細
sendAndReceive
ListenableFuture<Message> sendAndReceive(Message message)
デフォルトのルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。- パラメーター:
message
- メッセージ。- 戻り値:
ListenableFuture
sendAndReceive
ListenableFuture<Message> sendAndReceive(StringSE routingKey, Message message)
指定されたルーティングキーを使用して、デフォルトの交換にメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。- パラメーター:
routingKey
- ルーティングキー。message
- メッセージ。- 戻り値:
ListenableFuture
sendAndReceive
ListenableFuture<Message> sendAndReceive(StringSE exchange, StringSE routingKey, Message message)
指定された交換およびルーティングキーにメッセージを送信します。メッセージに correlationId プロパティが含まれている場合は、一意である必要があります。- パラメーター:
exchange
- 交換。routingKey
- ルーティングキー。message
- メッセージ。- 戻り値:
ListenableFuture
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(ObjectSE object)
オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
object
- 変換するオブジェクト。- 戻り値:
ListenableFuture
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(StringSE routingKey, ObjectSE object)
オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
routingKey
- ルーティングキー。object
- 変換するオブジェクト。- 戻り値:
ListenableFuture
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE object)
オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
exchange
- 交換。routingKey
- ルーティングキー。object
- 変換するオブジェクト。- 戻り値:
ListenableFuture
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(ObjectSE object, MessagePostProcessor messagePostProcessor)
オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
object
- 変換するオブジェクト。messagePostProcessor
- ポストプロセッサー。- 戻り値:
ListenableFuture
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)
オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
routingKey
- ルーティングキー。object
- 変換するオブジェクト。messagePostProcessor
- ポストプロセッサー。- 戻り値:
ListenableFuture
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor)
MessagePostProcessor
を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
exchange
- 交換routingKey
- ルーティングキー。object
- 変換するオブジェクト。messagePostProcessor
- ポストプロセッサー。- 戻り値:
ListenableFuture
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(ObjectSE object, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
object
- 変換するオブジェクト。responseType
- レスポンス型。- 戻り値:
ListenableFuture
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、指定されたルーティングキーを使用してデフォルトの交換に送信します。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
routingKey
- ルーティングキー。object
- 変換するオブジェクト。responseType
- レスポンス型。- 戻り値:
ListenableFuture
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE object, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
exchange
- 交換。routingKey
- ルーティングキー。object
- 変換するオブジェクト。responseType
- レスポンス型。- 戻り値:
ListenableFuture
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、デフォルトのルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
object
- 変換するオブジェクト。messagePostProcessor
- ポストプロセッサー。responseType
- レスポンス型。- 戻り値:
ListenableFuture
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
オブジェクトをメッセージに変換し、MessagePostProcessor
を呼び出した後、指定されたルーティングキーを使用してデフォルトの交換に送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
routingKey
- ルーティングキー。object
- 変換するオブジェクト。messagePostProcessor
- ポストプロセッサー。responseType
- レスポンス型。- 戻り値:
ListenableFuture
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
MessagePostProcessor
を呼び出した後、オブジェクトをメッセージに変換し、指定された交換およびルーティングキーに送信します。ポストプロセッサーが correlationId プロパティを追加する場合、一意である必要があります。- 型パラメーター:
C
- 期待される結果型。- パラメーター:
exchange
- 交換routingKey
- ルーティングキー。object
- 変換するオブジェクト。messagePostProcessor
- ポストプロセッサー。responseType
- レスポンス型。- 戻り値:
ListenableFuture