Class ApacheCommonsFileTailingMessageProducer
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.file.tail.FileTailingMessageProducerSupport
org.springframework.integration.file.tail.ApacheCommonsFileTailingMessageProducer
- All Implemented Interfaces:
org.apache.commons.io.input.TailerListener,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.beans.factory.SmartInitializingSingleton,org.springframework.context.ApplicationContextAware,org.springframework.context.ApplicationEventPublisherAware,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.core.MessageProducer,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.ManageableSmartLifecycle,org.springframework.integration.support.management.TrackableComponent
public class ApacheCommonsFileTailingMessageProducer extends FileTailingMessageProducerSupport implements org.apache.commons.io.input.TailerListener
File tailer that delegates to the Apache Commons Tailer.
- Since:
- 3.0
-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.integration.file.tail.FileTailingMessageProducerSupport
FileTailingMessageProducerSupport.FileTailingEvent, FileTailingMessageProducerSupport.FileTailingIdleEvent -
Field Summary
Fields inherited from class org.springframework.integration.file.tail.FileTailingMessageProducerSupport
DEFAULT_TAIL_ATTEMPTS_DELAYFields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLock -
Constructor Summary
Constructors Constructor Description ApacheCommonsFileTailingMessageProducer() -
Method Summary
Modifier and Type Method Description protected voiddoStart()protected voiddoStop()voidfileNotFound()voidfileRotated()java.lang.StringgetComponentType()voidhandle(java.lang.Exception ex)voidhandle(java.lang.String line)voidinit(org.apache.commons.io.input.Tailer tailer)voidsetEnd(boolean end)If true, tail from the end of the file, otherwise include all lines from the beginning.voidsetPollingDelay(long pollingDelay)The delay between checks of the file for new content in milliseconds.voidsetReopen(boolean reopen)If true, close and reopen the file between reading chunks; default false.Methods inherited from class org.springframework.integration.file.tail.FileTailingMessageProducerSupport
getFile, getMissingFileDelay, getTaskExecutor, publish, send, setApplicationEventPublisher, setFile, setIdleEventInterval, setTailAttemptsDelay, setTaskExecutorMethods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherMethods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
-
Constructor Details
-
ApacheCommonsFileTailingMessageProducer
public ApacheCommonsFileTailingMessageProducer()
-
-
Method Details
-
setPollingDelay
public void setPollingDelay(long pollingDelay)The delay between checks of the file for new content in milliseconds.- Parameters:
pollingDelay- The delay.
-
setEnd
public void setEnd(boolean end)If true, tail from the end of the file, otherwise include all lines from the beginning. Default true.- Parameters:
end- true or false
-
setReopen
public void setReopen(boolean reopen)If true, close and reopen the file between reading chunks; default false.- Parameters:
reopen- true or false.
-
getComponentType
public java.lang.String getComponentType()- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classFileTailingMessageProducerSupport
-
doStart
protected void doStart()- Overrides:
doStartin classFileTailingMessageProducerSupport
-
doStop
protected void doStop()- Overrides:
doStopin classFileTailingMessageProducerSupport
-
init
public void init(org.apache.commons.io.input.Tailer tailer)- Specified by:
initin interfaceorg.apache.commons.io.input.TailerListener
-
fileNotFound
public void fileNotFound()- Specified by:
fileNotFoundin interfaceorg.apache.commons.io.input.TailerListener
-
fileRotated
public void fileRotated()- Specified by:
fileRotatedin interfaceorg.apache.commons.io.input.TailerListener
-
handle
public void handle(java.lang.String line)- Specified by:
handlein interfaceorg.apache.commons.io.input.TailerListener
-
handle
public void handle(java.lang.Exception ex)- Specified by:
handlein interfaceorg.apache.commons.io.input.TailerListener
-