クラス CharacterStreamReadingMessageSource
java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<StringSE>
org.springframework.integration.stream.CharacterStreamReadingMessageSource
- 実装されたすべてのインターフェース:
Aware
、BeanFactoryAware
、BeanNameAware
、DisposableBean
、InitializingBean
、ApplicationEventPublisherAware
、MessageSource<StringSE>
、IntegrationPattern
、NamedComponent
、IntegrationInboundManagement
、IntegrationManagement
public class CharacterStreamReadingMessageSource
extends AbstractMessageSource<StringSE>
implements ApplicationEventPublisherAware
Readers
SE のポーリング可能なソース。- 作成者:
- Mark Fisher, Gary Russell, Artem Bilan, Christian Tzolov
ネストされたクラスのサマリー
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドサマリー
クラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターのサマリー
コンストラクター説明プロバイダーリーダーを使用してインスタンスを構築します。CharacterStreamReadingMessageSource
(ReaderSE reader, int bufferSize) プロバイダーリーダーとバッファーサイズを使用してインスタンスを構築します。CharacterStreamReadingMessageSource
(ReaderSE reader, int bufferSize, boolean blockToDetectEOF) 提供されたリーダーとバッファーサイズでインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明サブクラスはこのメソッドを実装する必要があります。void
setApplicationEventPublisher
(ApplicationEventPublisher applicationEventPublisher) stdin()
System.in
SE から読み取るソースを作成します。System.in
SE から読み取るソースを作成します。System.in
SE から読み取るソースを作成します。System.in
SE から読み取るソースを作成します。クラス org.springframework.integration.endpoint.AbstractMessageSource から継承されたメソッド
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
クラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたメソッド
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs, isObserved, registerObservationRegistry
インターフェース org.springframework.integration.core.MessageSource から継承されたメソッド
getIntegrationPatternType
コンストラクターの詳細
CharacterStreamReadingMessageSource
プロバイダーリーダーを使用してインスタンスを構築します。リーダーの準備ができていない場合、AbstractMessageSource.receive()
はnull
を返します。- パラメーター:
reader
- リーダー。
CharacterStreamReadingMessageSource
プロバイダーリーダーとバッファーサイズを使用してインスタンスを構築します。リーダーの準備ができていない場合、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
- バッファサイズ。負の場合は、BufferedReader
SE のデフォルトを使用します。blockToDetectEOF
- データが利用可能になるまでスレッドをブロックし、EOF でStreamClosedEvent
を公開する場合は true。- 導入:
- 5.0
メソッドの詳細
setApplicationEventPublisher
- 次で指定:
- インターフェース
ApplicationEventPublisherAware
のsetApplicationEventPublisher
getComponentType
- 次で指定:
- インターフェース
NamedComponent
のgetComponentType
doReceive
クラスからコピーされた説明:AbstractMessageSource
サブクラスはこのメソッドを実装する必要があります。通常、戻り値は T 型のpayload
ですが、戻り値はペイロードが T 型のMessage
インスタンスでもかまいません。追加のヘッダーの作成に使用されるAbstractIntegrationMessageBuilder
にすることもできます。- 次で指定:
- クラス
AbstractMessageSource<StringSE>
のdoReceive
- 戻り値:
- 返された値。
stdin
System.in
SE から読み取るソースを作成します。EOF は検出されません。- 戻り値:
- ストリーム。
stdin
System.in
SE から読み取るソースを作成します。EOF は検出されません。- パラメーター:
charsetName
- バイトを文字列に変換するときに使用する文字セット。- 戻り値:
- ストリーム。
stdinPipe
System.in
SE から読み取るソースを作成します。EOF が検出され、アプリケーションコンテキストが閉じられます。- 戻り値:
- ストリーム。
- 導入:
- 5.0
- 関連事項:
stdinPipe
System.in
SE から読み取るソースを作成します。EOF が検出され、アプリケーションコンテキストが閉じられます。- パラメーター:
charsetName
- バイトを文字列に変換するときに使用する文字セット。- 戻り値:
- ストリーム。
- 導入:
- 5.0
- 関連事項: