クラス ByteStreamReadingMessageSource

実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, MessageSource<byte[]>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement

public class ByteStreamReadingMessageSource extends AbstractMessageSource<byte[]>
InputStreamSE からバイトを受信するためのポーリング可能なソース。
導入:
7.0
作成者:
Mark Fisher, Artem Bilan, Christian Tzolov, Ngoc Nhan
  • コンストラクターの詳細

    • ByteStreamReadingMessageSource

      public ByteStreamReadingMessageSource(InputStreamSE stream)
    • ByteStreamReadingMessageSource

      public ByteStreamReadingMessageSource(InputStreamSE stream, int bufferSize)
  • 方法の詳細

    • setBytesPerMessage

      public void setBytesPerMessage(int bytesPerMessage)
    • setShouldTruncate

      public void setShouldTruncate(boolean shouldTruncate)
    • getComponentType

      public StringSE getComponentType()
    • doReceive

      protected byte @Nullable [] doReceive()
      クラスからコピーされた説明: AbstractMessageSource
      サブクラスはこのメソッドを実装する必要があります。通常、返される値は型 T の payload になりますが、返される値はペイロードが型 T である Message インスタンスである場合もあります。また、追加のヘッダーの設定に使用される AbstractIntegrationMessageBuilder である場合もあります。
      次で指定:
      クラス AbstractMessageSource<byte[]> の doReceive 
      戻り値:
      返された値。