public class OSDelegatingFileTailingMessageProducer extends FileTailingMessageProducerSupport implements SchedulingAwareRunnable
FileTailingMessageProducerSupport.FileTailingEventlifecycleCondition, lifecycleLocklogger| Constructor and Description |
|---|
OSDelegatingFileTailingMessageProducer() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart()
Takes no action by default.
|
protected void |
doStop()
Takes no action by default.
|
String |
getCommand() |
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
boolean |
isLongLived() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
run()
Reads lines from stdout and sends in a message to the output channel.
|
void |
setOptions(String options) |
getFile, getMissingFileDelay, getTaskExecutor, publish, send, setApplicationEventPublisher, setFile, setTailAttemptsDelay, setTaskExecutorgetMessagingTemplate, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrackdoStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic OSDelegatingFileTailingMessageProducer()
public void setOptions(String options)
public String getCommand()
public String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class FileTailingMessageProducerSupportpublic boolean isLongLived()
isLongLived in interface SchedulingAwareRunnableprotected void onInit()
IntegrationObjectSupportonInit in class MessageProducerSupportprotected void doStart()
MessageProducerSupportdoStart in class MessageProducerSupportprotected void doStop()
MessageProducerSupportdoStop in class MessageProducerSupport