クラス CharacterStreamReadingMessageSource

java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<StringSE>
org.springframework.integration.stream.inbound.CharacterStreamReadingMessageSource
実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationEventPublisherAware, MessageSource<StringSE>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement
public class CharacterStreamReadingMessageSource extends AbstractMessageSource<StringSE> implements ApplicationEventPublisherAware
ReadersSE のポーリング可能なソース。
導入:
7.0
作成者:
Mark Fisher, Gary Russell, Artem Bilan, Christian Tzolov, Ngoc Nhan

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

    • 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。

  • 方法の詳細