クラス AbstractPooledBufferByteArraySerializer

java.lang.ObjectSE
org.springframework.integration.ip.tcp.serializer.AbstractByteArraySerializer
org.springframework.integration.ip.tcp.serializer.AbstractPooledBufferByteArraySerializer
実装済みのインターフェース一覧:
Aware, ApplicationEventPublisherAware, Deserializer<byte[]>, Serializer<byte[]>
既知の直属サブクラス
ByteArrayCrLfSerializer, ByteArrayRawSerializer, ByteArraySingleTerminatorSerializer, ByteArrayStxEtxSerializer
public abstract class AbstractPooledBufferByteArraySerializer extends AbstractByteArraySerializer
必要なバッファーサイズを決定できないデシリアライザーの基本クラス。オプションでバッファをプールします。
導入:
4.3
作成者:
Gary Russell, Ngoc Nhan

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

    • AbstractPooledBufferByteArraySerializer

      public AbstractPooledBufferByteArraySerializer()

  • 方法の詳細

    • setPoolSize

      public void setPoolSize(int size)
      逆直列化バッファーのプールサイズを設定します。
      パラメーター:
      size - サイズ、無制限の場合は -1。
      導入:
      4.3

    • setPoolWaitTimeout

      public void setPoolWaitTimeout(long poolWaitTimeout)
      プールが構成されている場合、プール待機タイムアウトを設定します。デフォルトは無制限です。
      パラメーター:
      poolWaitTimeout - タイムアウト。

    • deserialize

      public final byte[] deserialize(InputStreamSE inputStream) throws IOExceptionSE
      例外:
      IOExceptionSE

    • doDeserialize

      protected abstract byte[] doDeserialize(InputStreamSE inputStream, byte[] buffer) throws IOExceptionSE
      パラメーター:
      inputStream - 入力ストリーム。
      buffer - 生の作業バッファ (maxMessageSize)。
      戻り値:
      デコードされたバイト。
      例外:
      IOExceptionSE - io 例外。
      導入:
      4.3

    • copyToSizedArray

      protected byte[] copyToSizedArray(byte[] buffer, int size)
      size バイトを正確に size バイト長の新しいバッファーにコピーします。プールが使用されておらず、配列がすでに正しい長さである場合は、単に返されます。
      パラメーター:
      buffer - データを含むバッファ。
      size - コピーするバイト数。
      戻り値:
      新しいバッファ、またはすでに正しいサイズでありプールがない場合は buffer パラメーター。