パッケージ org.springframework.messaging.rsocket

クラス PayloadUtils

java.lang.ObjectSE
org.springframework.messaging.rsocket.PayloadUtils
public abstract class PayloadUtils extends ObjectSE
DataBuffer から Payload を作成するための静的ユーティリティメソッド。
導入:
5.2
作成者:
Rossen Stoyanchev

  • コンストラクターの詳細

    • PayloadUtils

      public PayloadUtils()

  • メソッドの詳細

    • retainDataAndReleasePayload

      public static DataBuffer retainDataAndReleasePayload(io.rsocket.Payload payload, DataBufferFactory bufferFactory)
      このメソッドを使用して、Payload のデータ部分をスライス、保持、ラップし、Payload を解放します。これは、ペイロードメタデータがすでに読み込まれていることを前提とし、ダウンストリームコードは DataBuffer のみを認識する必要があることを保証します。
      パラメーター:
      payload - 処理するペイロード
      bufferFactory - ラップする DataBufferFactory
      戻り値:
      作成された DataBuffer インスタンス

    • createPayload

      public static io.rsocket.Payload createPayload(DataBuffer data, DataBuffer metadata)
      指定されたメタデータとデータからペイロードを作成します。

      少なくとも 1 つが NettyDataBuffer の場合、ByteBufPayload は、基になるネイティブ ByteBuf を取得するか、必要に応じて Unpooled.wrappedBuffer(ByteBuffer...) を使用して作成されます。それ以外の場合、両方が DefaultDataBuffer であれば、DefaultPayload が作成されます。

      パラメーター:
      data - ペイロードのデータ部分
      metadata - ペイロードのメタデータ部分
      戻り値:
      作成されたペイロード

    • createPayload

      public static io.rsocket.Payload createPayload(DataBuffer data)
      データのみでペイロードを作成します。入力が NettyDataBuffer の場合、作成されるペイロードは ByteBufPayload です。それ以外の場合は、DefaultPayload です。
      パラメーター:
      data - ペイロードのデータ部分
      戻り値:
      作成されたペイロード