パッケージ org.springframework.amqp.rabbit.core

インターフェース RabbitOperations

すべてのスーパーインターフェース:
AmqpTemplate, Lifecycle
すべての既知の実装クラス:
BatchingRabbitTemplate、RabbitTemplate、TestRabbitTemplate
public interface RabbitOperations extends AmqpTemplate, Lifecycle
Amqp 機能の Rabbit 固有のメソッド。
作成者:
Mark Pollack, Mark Fisher, Gary Russell, Artem Bilan

  • メソッドの詳細

    • execute

      @Nullable <T> T execute(ChannelCallback<T> action) throws AmqpException
      チャネルでコールバックを実行し、その後チャネルを確実に閉じます。
      型パラメーター:
      T - 戻り値の型。
      パラメーター:
      action - コールバック。
      戻り値:
      ChannelCallback.doInRabbit(com.rabbitmq.client.Channel) からの結果。
      例外:
      AmqpException - 発生した場合。

    • invoke

      @Nullable default <T> T invoke(RabbitOperations.OperationsCallback<T> action) throws AmqpException
      コールバックを呼び出し、専用のスレッドバインドチャネルでテンプレート引数に対してすべての操作を実行し、後で確実にチャネルを閉じます。
      型パラメーター:
      T - 戻り値の型。
      パラメーター:
      action - コールバック。
      戻り値:
      RabbitOperations.OperationsCallback.doInRabbit(RabbitOperations operations) からの結果。
      例外:
      AmqpException - 発生した場合。
      導入:
      2.0

    • invoke

      @Nullable <T> T invoke(RabbitOperations.OperationsCallback<T> action, @Nullable com.rabbitmq.client.ConfirmCallback acks, @Nullable com.rabbitmq.client.ConfirmCallback nacks)
      同じチャネルで操作を呼び出します。コールバックが必要な場合は、両方のコールバックを指定する必要があります。
      型パラメーター:
      T - 戻り値の型。
      パラメーター:
      action - コールバック。
      acks - ack の確認コールバック。
      nacks - nack の確認コールバック。
      戻り値:
      アクションメソッドの結果。
      導入:
      2.1

    • waitForConfirms

      boolean waitForConfirms(long timeout) throws AmqpException
      基礎となる専用チャネルに委譲して、確認を待ちます。パブリッシャーの確認用に接続ファクトリを構成する必要があり、このメソッドは invoke(OperationsCallback) 操作の範囲内で呼び出す必要があります。CachingConnectionFactory#setPublisherConfirms(true) が必要です。
      パラメーター:
      timeout - タイムアウト
      戻り値:
      ack を受信し、nacks を受信しない場合は true。
      例外:
      AmqpException - 発生した場合。
      導入:
      2.0
      関連事項:
      • Channel.waitForConfirms(long)

    • waitForConfirmsOrDie

      void waitForConfirmsOrDie(long timeout) throws AmqpException
      基礎となる専用チャネルに委譲して、確認を待ちます。パブリッシャーの確認用に接続ファクトリを構成する必要があり、このメソッドは invoke(OperationsCallback) 操作の範囲内で呼び出す必要があります。CachingConnectionFactory#setPublisherConfirms(true) が必要です。
      パラメーター:
      timeout - タイムアウト
      例外:
      AmqpException - 発生した場合。
      導入:
      2.0
      関連事項:
      • Channel.waitForConfirmsOrDie(long)

    • getConnectionFactory

      ConnectionFactory getConnectionFactory()
      この操作の接続ファクトリを返します。
      戻り値:
      接続ファクトリ。
      導入:
      2.0

    • send

      default void send(StringSE routingKey, Message message, CorrelationData correlationData) throws AmqpException
      特定のルーティングキーを使用して、デフォルトの交換にメッセージを送信します。
      パラメーター:
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合
      導入:
      2.3

    • send

      void send(StringSE exchange, StringSE routingKey, Message message, CorrelationData correlationData) throws AmqpException
      特定のルーティングキーを使用して、特定の交換にメッセージを送信します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合

    • correlationConvertAndSend

      void correlationConvertAndSend(ObjectSE message, CorrelationData correlationData) throws AmqpException
      Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。
      パラメーター:
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合

    • convertAndSend

      void convertAndSend(StringSE routingKey, ObjectSE message, CorrelationData correlationData) throws AmqpException
      Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。
      パラメーター:
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合

    • convertAndSend

      void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE message, CorrelationData correlationData) throws AmqpException
      Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合

    • convertAndSend

      void convertAndSend(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
      Java オブジェクトを Amqp Message に変換し、デフォルトのルーティングキーを使用してデフォルトの取引所に送信します。
      パラメーター:
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合

    • convertAndSend

      void convertAndSend(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
      Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用してデフォルトの交換に送信します。
      パラメーター:
      routingKey - ルーティングキー
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合

    • convertAndSend

      void convertAndSend(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
      Java オブジェクトを Amqp Message に変換し、特定のルーティングキーを使用して特定の取引所に送信します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceive

      @Nullable ObjectSE convertSendAndReceive(ObjectSE message, CorrelationData correlationData) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
      パラメーター:
      message - 送信するメッセージ。
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceive

      @Nullable ObjectSE convertSendAndReceive(StringSE routingKey, ObjectSE message, CorrelationData correlationData) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
      パラメーター:
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceive

      @Nullable ObjectSE convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message, CorrelationData correlationData) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceive

      @Nullable ObjectSE convertSendAndReceive(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
      パラメーター:
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceive

      @Nullable ObjectSE convertSendAndReceive(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
      パラメーター:
      routingKey - ルーティングキー
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceive

      @Nullable ObjectSE convertSendAndReceive(StringSE exchange, StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceiveAsType

      @Nullable <T> T convertSendAndReceiveAsType(ObjectSE message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
      型パラメーター:
      T - 型。
      パラメーター:
      message - 送信するメッセージ。
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      responseType - 返信を変換する型。
      戻り値:
      ある場合のレスポンス。
      例外:
      AmqpException - 問題がある場合。

    • convertSendAndReceiveAsType

      @Nullable <T> T convertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
      型パラメーター:
      T - 型。
      パラメーター:
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      responseType - 返信を変換する型。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceiveAsType

      @Nullable default <T> T convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
      型パラメーター:
      T - 型。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      responseType - 返信を変換する型。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceiveAsType

      @Nullable <T> T convertSendAndReceiveAsType(ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、デフォルトのルーティングキーを使用してデフォルトの交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
      型パラメーター:
      T - 型。
      パラメーター:
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      responseType - 返信を変換する型。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceiveAsType

      @Nullable <T> T convertSendAndReceiveAsType(StringSE routingKey, ObjectSE message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用してデフォルトの交換に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
      型パラメーター:
      T - 型。
      パラメーター:
      routingKey - ルーティングキー
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      responseType - 返信を変換する型。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • convertSendAndReceiveAsType

      @Nullable <T> T convertSendAndReceiveAsType(StringSE exchange, StringSE routingKey, ObjectSE message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData, ParameterizedTypeReference<T> responseType) throws AmqpException
      変換を伴う基本的な RPC パターン。メッセージに変換された Java オブジェクトを、特定のルーティングキーを使用して特定の交換機に送信し、レスポンスの受信を試みて、それを Java オブジェクトに変換します。実装は、通常、reply-to ヘッダーを専用キューに設定し、タイムアウトによって制限された時間まで待機します。SmartMessageConverter が必要です。
      型パラメーター:
      T - 型。
      パラメーター:
      exchange - 取引所の名前
      routingKey - ルーティングキー
      message - 送信するメッセージ
      messagePostProcessor - 送信前にメッセージに適用するプロセッサー
      correlationData - パブリッシャーの確認を関連付けるためのデータ。
      responseType - 返信を変換する型。
      戻り値:
      ある場合のレスポンス
      例外:
      AmqpException - 問題がある場合

    • start

      default void start()
      次で指定:
      インターフェース Lifecycle の start 

    • stop

      default void stop()
      次で指定:
      インターフェース Lifecycle の stop 

    • isRunning

      default boolean isRunning()
      次で指定:
      インターフェース Lifecycle の isRunning