public class OSDelegatingFileTailingMessageProducer extends FileTailingMessageProducerSupport implements SchedulingAwareRunnable
FileTailingMessageProducerSupport.FileTailingEvent, FileTailingMessageProducerSupport.FileTailingIdleEvent
DEFAULT_TAIL_ATTEMPTS_DELAY
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
DEFAULT_PHASE
コンストラクターと説明 |
---|
OSDelegatingFileTailingMessageProducer() |
修飾子と型 | メソッドと説明 |
---|---|
protected void | doStart() デフォルトでは何もしません。 |
protected void | doStop() デフォルトでは何もしません。 |
StringSE | getCommand() |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
boolean | isLongLived() |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | run() stdout から行を読み取り、出力チャネルにメッセージを送信します。 |
void | setEnableStatusReader(boolean enableStatusReader) false の場合、stderr をキャプチャーするためのスレッドは開始されず、stderr 出力は無視されます |
void | setOptions(StringSE options) |
getFile, getMissingFileDelay, getTaskExecutor, publish, send, setApplicationEventPublisher, setFile, setIdleEventInterval, setTailAttemptsDelay, setTaskExecutor
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getBeanName, getComponentName
public void setOptions(StringSE options)
public void setEnableStatusReader(boolean enableStatusReader)
enableStatusReader
- 正しいか間違っているか public StringSE getCommand()
public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
FileTailingMessageProducerSupport
の getComponentType
public boolean isLongLived()
SchedulingAwareRunnable
の isLongLived
protected void onInit()
IntegrationObjectSupport
MessageProducerSupport
の onInit
protected void doStart()
MessageProducerSupport
FileTailingMessageProducerSupport
の doStart
protected void doStop()
MessageProducerSupport
FileTailingMessageProducerSupport
の doStop
public void run()
RunnableSE
の runSE