クラス ByteStreamReadingMessageSource

実装されているすべてのインターフェース:
AwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanMessageSource<byte[]>IntegrationPatternNamedComponentIntegrationInboundManagementIntegrationManagement

public class ByteStreamReadingMessageSource extends AbstractMessageSource<byte[]>
InputStreamSE からバイトを受信するためのポーリング可能なソース。
作成者:
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[] doReceive()
      クラスからコピーされた説明: AbstractMessageSource
      サブクラスはこのメソッドを実装する必要があります。通常、返される値は型 T の payload になりますが、返される値はペイロードが型 T である Message インスタンスである場合もあります。また、追加のヘッダーの設定に使用される AbstractIntegrationMessageBuilder である場合もあります。
      次で指定:
      クラス AbstractMessageSource<byte[]>doReceive 
      戻り値:
      返された値。