public class ApacheCommonsFileTailingMessageProducer extends FileTailingMessageProducerSupport implements org.apache.commons.io.input.TailerListener
FileTailingMessageProducerSupport.FileTailingEvent, FileTailingMessageProducerSupport.FileTailingIdleEvent
DEFAULT_TAIL_ATTEMPTS_DELAY
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
DEFAULT_PHASE
コンストラクターと説明 |
---|
ApacheCommonsFileTailingMessageProducer() |
修飾子と型 | メソッドと説明 |
---|---|
protected void | doStart() デフォルトでは何もしません。 |
protected void | doStop() デフォルトでは何もしません。 |
void | fileNotFound() |
void | fileRotated() |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
void | handle(ExceptionSE ex) |
void | handle(StringSE line) |
void | init(org.apache.commons.io.input.Tailer tailer) |
void | setEnd(boolean end) true の場合、ファイルの末尾から末尾、それ以外の場合は先頭からすべての行が含まれます。 |
void | setPollingDelay(long pollingDelay) 新しいコンテンツのファイルをチェックする間隔(ミリ秒単位)。 |
void | setReopen(boolean reopen) true の場合、チャンクの読み取りの間にファイルを閉じて再度開きます。デフォルトは false。 |
getFile, getMissingFileDelay, getTaskExecutor, publish, send, setApplicationEventPublisher, setFile, setIdleEventInterval, setTailAttemptsDelay, setTaskExecutor
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
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
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getBeanName, getComponentName
public void setPollingDelay(long pollingDelay)
pollingDelay
- 遅延。public void setEnd(boolean end)
end
- 正しいか間違っているか public void setReopen(boolean reopen)
reopen
- 正しいか間違っているか。public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
FileTailingMessageProducerSupport
の getComponentType
protected void doStart()
MessageProducerSupport
FileTailingMessageProducerSupport
の doStart
protected void doStop()
MessageProducerSupport
FileTailingMessageProducerSupport
の doStop
public void init(org.apache.commons.io.input.Tailer tailer)
org.apache.commons.io.input.TailerListener
の init
public void fileNotFound()
org.apache.commons.io.input.TailerListener
の fileNotFound
public void fileRotated()
org.apache.commons.io.input.TailerListener
の fileRotated
public void handle(StringSE line)
org.apache.commons.io.input.TailerListener
の handle
public void handle(ExceptionSE ex)
org.apache.commons.io.input.TailerListener
の handle