public abstract class FileTailingMessageProducerSupport
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.context.ApplicationEventPublisherAware
| Modifier and Type | Class and Description |
|---|---|
static class |
FileTailingMessageProducerSupport.FileTailingEvent |
static class |
FileTailingMessageProducerSupport.FileTailingIdleEvent |
lifecycleCondition, lifecycleLock| Constructor and Description |
|---|
FileTailingMessageProducerSupport() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart() |
protected void |
doStop() |
java.lang.String |
getComponentType() |
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, toStringpublic 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()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.context.IntegrationObjectSupportprotected void send(java.lang.String line)
protected void publish(java.lang.String message)
protected void doStart()
doStart in class org.springframework.integration.endpoint.MessageProducerSupportprotected void doStop()
doStop in class org.springframework.integration.endpoint.MessageProducerSupport