クラス CharacterStreamReadingMessageSource

実装されたすべてのインターフェース:
AwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanApplicationEventPublisherAwareMessageSource<StringSE>IntegrationPatternNamedComponentIntegrationInboundManagementIntegrationManagement

public class CharacterStreamReadingMessageSource extends AbstractMessageSource<StringSE> implements ApplicationEventPublisherAware
ReadersSE のポーリング可能なソース。
作成者:
Mark Fisher, Gary Russell, Artem Bilan, Christian Tzolov
  • コンストラクターの詳細

    • CharacterStreamReadingMessageSource

      public CharacterStreamReadingMessageSource(ReaderSE reader)
      プロバイダーリーダーを使用してインスタンスを構築します。リーダーの準備ができていない場合、AbstractMessageSource.receive() は null を返します。
      パラメーター:
      reader - リーダー。
    • CharacterStreamReadingMessageSource

      public CharacterStreamReadingMessageSource(ReaderSE reader, int bufferSize)
      プロバイダーリーダーとバッファーサイズを使用してインスタンスを構築します。リーダーの準備ができていない場合、AbstractMessageSource.receive() は null を返します。
      パラメーター:
      reader - リーダー。
      bufferSize - バッファサイズ。
    • CharacterStreamReadingMessageSource

      public CharacterStreamReadingMessageSource(ReaderSE reader, int bufferSize, boolean blockToDetectEOF)
      提供されたリーダーとバッファーサイズでインスタンスを構築します。blockToDetectEOF が false の場合、リーダーの準備ができていないときに AbstractMessageSource.receive() は null を返します。true の場合、スレッドはデータが利用可能になるまでブロックします。基になるストリームが閉じられると、StreamClosedEvent が公開され、ApplicationListener を介してアプリケーションに通知されます。これは、たとえば、stdin を接続機能するときに役立ちます。
           cat foo.txt | java -jar my.jar
       
      または
           java -jar my.jar < foo.txt
       
      パラメーター:
      reader - リーダー。
      bufferSize - バッファサイズ。負の場合は、BufferedReaderSE のデフォルトを使用します。
      blockToDetectEOF - データが利用可能になるまでスレッドをブロックし、EOF で StreamClosedEvent を公開する場合は true。
      導入:
      5.0
  • メソッドの詳細