public abstract class FileTailingMessageProducerSupport extends MessageProducerSupport implements ApplicationEventPublisherAware
| Modifier and Type | Class and Description |
|---|---|
static class |
FileTailingMessageProducerSupport.FileTailingEvent |
static class |
FileTailingMessageProducerSupport.FileTailingIdleEvent |
lifecycleCondition, lifecycleLockEXPRESSION_PARSER, loggerDEFAULT_PHASE| Constructor and Description |
|---|
FileTailingMessageProducerSupport() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart()
Takes no action by default.
|
protected void |
doStop()
Takes no action by default.
|
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected File |
getFile() |
protected long |
getMissingFileDelay() |
protected TaskExecutor |
getTaskExecutor() |
protected void |
publish(String message) |
protected void |
send(String line) |
void |
setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void |
setFile(File file)
The name of the file you wish to tail.
|
void |
setIdleEventInterval(long idleEventInterval)
How often to emit
FileTailingMessageProducerSupport.FileTailingIdleEvents in milliseconds. |
void |
setTailAttemptsDelay(long tailAttemptsDelay)
The delay in milliseconds between attempts to tail a non-existent file,
or between attempts to execute a process if it fails for any reason.
|
void |
setTaskExecutor(TaskExecutor taskExecutor)
A task executor; default is a
SimpleAsyncTaskExecutor. |
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrackdestroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetBeanName, getComponentNamepublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface ApplicationEventPublisherAwarepublic void setFile(File file)
file - The absolute path of the file.protected File getFile()
public void setTaskExecutor(TaskExecutor taskExecutor)
SimpleAsyncTaskExecutor.taskExecutor - The task executor.public void setTailAttemptsDelay(long tailAttemptsDelay)
tailAttemptsDelay - the delay.public void setIdleEventInterval(long idleEventInterval)
FileTailingMessageProducerSupport.FileTailingIdleEvents in milliseconds.idleEventInterval - the interval.protected long getMissingFileDelay()
protected TaskExecutor getTaskExecutor()
public String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class IntegrationObjectSupportprotected void send(String line)
protected void publish(String message)
protected void doStart()
MessageProducerSupportdoStart in class MessageProducerSupportprotected void doStop()
MessageProducerSupportdoStop in class MessageProducerSupport