public abstract class FileTailingMessageProducerSupport extends MessageProducerSupport implements org.springframework.context.ApplicationEventPublisherAware
| Modifier and Type | Class and Description |
|---|---|
static class |
FileTailingMessageProducerSupport.FileTailingEvent |
logger| Constructor and Description |
|---|
FileTailingMessageProducerSupport() |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected java.io.File |
getFile() |
protected long |
getMissingFileDelay() |
protected org.springframework.core.task.TaskExecutor |
getTaskExecutor() |
protected void |
publish(java.lang.String message) |
protected void |
send(java.lang.String line) |
void |
setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher) |
void |
setFile(java.io.File file)
The name of the file you wish to tail.
|
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(org.springframework.core.task.TaskExecutor taskExecutor)
A task executor; default is a
SimpleAsyncTaskExecutor. |
doStart, doStop, onInit, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrackgetPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAwarepublic void setFile(java.io.File file)
file - The absolute path of the file.protected java.io.File getFile()
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
SimpleAsyncTaskExecutor.taskExecutor - public void setTailAttemptsDelay(long tailAttemptsDelay)
tailAttemptsDelay - the delay.protected long getMissingFileDelay()
protected org.springframework.core.task.TaskExecutor getTaskExecutor()
public java.lang.String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class IntegrationObjectSupportprotected void send(java.lang.String line)
protected void publish(java.lang.String message)