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, lifecycleLock
EXPRESSION_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.FileTailingIdleEvent s 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, setShouldTrack
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher
in interface org.springframework.context.ApplicationEventPublisherAware
public 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.FileTailingIdleEvent
s in milliseconds.idleEventInterval
- the interval.protected long getMissingFileDelay()
protected org.springframework.core.task.TaskExecutor getTaskExecutor()
public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class IntegrationObjectSupport
protected void send(java.lang.String line)
protected void publish(java.lang.String message)
protected void doStart()
MessageProducerSupport
doStart
in class MessageProducerSupport
protected void doStop()
MessageProducerSupport
doStop
in class MessageProducerSupport