パッケージ org.springframework.amqp.client

クラス ProtonUtils

java.lang.ObjectSE
org.springframework.amqp.client.ProtonUtils
public final class ProtonUtils extends ObjectSE
ProtonJ と Spring API 間のユーティリティメソッド。
導入:
4.1
作成者:
Artem Bilan

  • 方法の詳細

    • toProtonMessage

      public static org.apache.qpid.protonj2.client.Message<?> toProtonMessage(Message message)
      Spring AMQP メッセージを ProtonJ メッセージに変換します。
      パラメーター:
      message - 変換元の Spring AMQP メッセージ。
      戻り値:
      提供された Spring AMQP メッセージに基づく ProtonJ メッセージ。

    • fromProtonMessage

      public static Message fromProtonMessage(org.apache.qpid.protonj2.client.Message<?> message)
      ProtonJ メッセージを Spring AMQP メッセージに変換します。バイナリ形式のメッセージのみがサポートされます。
      パラメーター:
      message - 変換元の ProtonJ メッセージ。
      戻り値:
      提供された ProtonJ メッセージに基づく Spring AMQP メッセージ。

    • toSupplier

      public static <T> SupplierSE<T> toSupplier(FutureSE<T> future, long timeout)
      FutureSE を SupplierSE に変換します。
      型パラメーター:
      T - 値の型。
      パラメーター:
      future - 転換すべき未来。
      timeout - FutureSE の結果を待つ時間。
      戻り値:
      提供された FutureSE を呼び出す SupplierSE。

    • toAmqpException

      public static AmqpException toAmqpException(ExceptionSE ex)
      例外を AmqpException 実装にラップします。
      パラメーター:
      ex - Proton クライアントからの例外をラップします。
      戻り値:
      AmqpException の実装。

    • toAmqpException

      public static AmqpException toAmqpException(ExecutionExceptionSE ex)
      ExecutionExceptionSE を AmqpException 実装にラップします。
      パラメーター:
      ex - Proton クライアントからの例外をラップします。
      戻り値:
      AmqpException の実装。

    • toAmqpException

      public static AmqpException toAmqpException(org.apache.qpid.protonj2.client.exceptions.ClientException ex)
      ClientException を AmqpException 実装にラップします。
      パラメーター:
      ex - Proton クライアントからの例外をラップします。
      戻り値:
      AmqpException の実装。