パッケージ org.springframework.integration.stream

クラス ByteStreamReadingMessageSource

java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<byte[]>
org.springframework.integration.stream.ByteStreamReadingMessageSource
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、MessageSource<byte[]>、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement
public class ByteStreamReadingMessageSource extends AbstractMessageSource<byte[]>
InputStreamSE からバイトを受信するためのポーリング可能なソース。
作成者:
Mark Fisher, Artem Bilan, Christian Tzolov

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

    • 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 
      戻り値:
      返された値。