Class TailAdapterSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,P>
org.springframework.integration.dsl.MessageProducerSpec<TailAdapterSpec,FileTailingMessageProducerSupport>
org.springframework.integration.file.dsl.TailAdapterSpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<FileTailingMessageProducerSupport>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class TailAdapterSpec extends org.springframework.integration.dsl.MessageProducerSpec<TailAdapterSpec,FileTailingMessageProducerSupport>
A
MessageProducerSpec for file tailing adapters.- Since:
- 5.0
-
Field Summary
-
Constructor Summary
Constructors Modifier Constructor Description protectedTailAdapterSpec() -
Method Summary
Modifier and Type Method Description TailAdapterSpecautoStartup(boolean autoStartup)TailAdapterSpecdelay(long delay)The delay between checks of the file for new content in milliseconds.protected FileTailingMessageProducerSupportdoGet()TailAdapterSpecenableStatusReader(boolean enableStatusReader)This field control the stderr events.TailAdapterSpecend(boolean end)Iftrue, tail from the end of the file, otherwise include all lines from the beginning.TailAdapterSpecerrorChannel(org.springframework.messaging.MessageChannel errorChannel)protected TailAdapterSpecfile(java.io.File file)TailAdapterSpecfileDelay(long fileDelay)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.TailAdapterSpecid(java.lang.String id)TailAdapterSpecidleEventInterval(long idleEventInterval)Specify the idle interval before start sending idle events.TailAdapterSpecnativeOptions(java.lang.String nativeOptions)Specify the options string for nativetailcommand.TailAdapterSpecoutputChannel(org.springframework.messaging.MessageChannel outputChannel)TailAdapterSpecphase(int phase)TailAdapterSpecreopen(boolean reopen)Iftrue, close and reopen the file between reading chunks.TailAdapterSpectaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)Configure a task executor.TailAdapterSpectaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler)Set a task scheduler - defaults to the integration 'taskScheduler'.Methods inherited from class org.springframework.integration.dsl.MessageProducerSpec
errorChannel, errorMessageStrategy, outputChannel, sendTimeout, shouldTrackMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
-
Constructor Details
-
TailAdapterSpec
protected TailAdapterSpec()
-
-
Method Details
-
file
-
nativeOptions
Specify the options string for nativetailcommand.- Parameters:
nativeOptions- the nativeOptions.- Returns:
- the spec.
- See Also:
OSDelegatingFileTailingMessageProducer.setOptions(String)
-
enableStatusReader
This field control the stderr events.- Parameters:
enableStatusReader- boolean to enable or disable events from stderr.- Returns:
- the spec
-
idleEventInterval
Specify the idle interval before start sending idle events.- Parameters:
idleEventInterval- interval in ms for the event idle time.- Returns:
- the spec.
-
taskExecutor
Configure a task executor. Defaults to aSimpleAsyncTaskExecutor.- Parameters:
taskExecutor- the taskExecutor.- Returns:
- the spec.
-
taskScheduler
Set a task scheduler - defaults to the integration 'taskScheduler'.- Parameters:
taskScheduler- the taskScheduler.- Returns:
- the spec.
-
delay
The delay between checks of the file for new content in milliseconds.- Parameters:
delay- the delay.- Returns:
- the spec.
- See Also:
ApacheCommonsFileTailingMessageProducer.setPollingDelay(long)
-
fileDelay
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.- Parameters:
fileDelay- the fileDelay.- Returns:
- the spec.
- See Also:
FileTailingMessageProducerSupport.setTailAttemptsDelay(long)
-
end
Iftrue, tail from the end of the file, otherwise include all lines from the beginning. Defaulttrue.- Parameters:
end- the end.- Returns:
- the spec.
- See Also:
ApacheCommonsFileTailingMessageProducer.setEnd(boolean)
-
reopen
Iftrue, close and reopen the file between reading chunks. Defaultfalse.- Parameters:
reopen- the reopen.- Returns:
- the spec.
- See Also:
ApacheCommonsFileTailingMessageProducer.setReopen(boolean)
-
id
- Overrides:
idin classorg.springframework.integration.dsl.MessageProducerSpec<TailAdapterSpec,FileTailingMessageProducerSupport>
-
phase
- Overrides:
phasein classorg.springframework.integration.dsl.MessageProducerSpec<TailAdapterSpec,FileTailingMessageProducerSupport>
-
autoStartup
- Overrides:
autoStartupin classorg.springframework.integration.dsl.MessageProducerSpec<TailAdapterSpec,FileTailingMessageProducerSupport>
-
outputChannel
- Overrides:
outputChannelin classorg.springframework.integration.dsl.MessageProducerSpec<TailAdapterSpec,FileTailingMessageProducerSupport>
-
errorChannel
- Overrides:
errorChannelin classorg.springframework.integration.dsl.MessageProducerSpec<TailAdapterSpec,FileTailingMessageProducerSupport>
-
doGet
- Overrides:
doGetin classorg.springframework.integration.dsl.IntegrationComponentSpec<TailAdapterSpec,FileTailingMessageProducerSupport>
-