public class OSDelegatingFileTailingMessageProducer extends FileTailingMessageProducerSupport implements org.springframework.scheduling.SchedulingAwareRunnable
FileTailingMessageProducerSupport.FileTailingEvent, FileTailingMessageProducerSupport.FileTailingIdleEventlifecycleCondition, lifecycleLock| Constructor and Description |
|---|
OSDelegatingFileTailingMessageProducer() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart() |
protected void |
doStop() |
java.lang.String |
getCommand() |
java.lang.String |
getComponentType() |
boolean |
isLongLived() |
protected void |
onInit() |
void |
run()
Reads lines from stdout and sends in a message to the output channel.
|
void |
setEnableStatusReader(boolean enableStatusReader)
If false, thread for capturing stderr will not be started
and stderr output will be ignored
|
void |
setOptions(java.lang.String options) |
getFile, getMissingFileDelay, getTaskExecutor, publish, send, setApplicationEventPublisher, setFile, setIdleEventInterval, setTailAttemptsDelay, setTaskExecutorafterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrackdestroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toStringpublic OSDelegatingFileTailingMessageProducer()
public void setOptions(java.lang.String options)
public void setEnableStatusReader(boolean enableStatusReader)
enableStatusReader - true or falsepublic java.lang.String getCommand()
public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class FileTailingMessageProducerSupportpublic boolean isLongLived()
isLongLived in interface org.springframework.scheduling.SchedulingAwareRunnableprotected void onInit()
onInit in class org.springframework.integration.endpoint.MessageProducerSupportprotected void doStart()
doStart in class FileTailingMessageProducerSupportprotected void doStop()
doStop in class FileTailingMessageProducerSupportpublic void run()
run in interface java.lang.Runnable