public abstract class FileTailingMessageProducerSupport extends MessageProducerSupport implements org.springframework.context.ApplicationEventPublisherAware
| Modifier and Type | Class and Description |
|---|---|
static class |
FileTailingMessageProducerSupport.FileTailingEvent |
static class |
FileTailingMessageProducerSupport.FileTailingIdleEvent |
lifecycleCondition, lifecycleLockEXPRESSION_PARSER, logger| 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.
|
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 |
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(org.springframework.core.task.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, 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, 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 - 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 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)
protected void doStart()
MessageProducerSupportdoStart in class MessageProducerSupportprotected void doStop()
MessageProducerSupportdoStop in class MessageProducerSupport