public abstract class AbstractDurableFileConsumer extends org.apache.camel.component.file.GenericFileConsumer<EventfulFileWrapper>
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
doPoll(String sha1) |
protected abstract void |
initialize(String remaining,
String sha1) |
protected boolean |
isMatched(org.apache.camel.component.file.GenericFile file,
String doneFileName,
List files) |
protected boolean |
pollDirectory(String fileName,
List list,
int depth) |
protected void |
updateFileHeaders(org.apache.camel.component.file.GenericFile<EventfulFileWrapper> file,
org.apache.camel.Message message) |
canPollMoreFiles, customProcessExchange, doStart, doStop, evaluateFileExpression, getCustomProcessor, ignoreCannotRetrieveFile, isEagerLimitMaxMessagesPerPoll, isInProgress, isMatched, isRetrieveFile, isValidFile, poll, postPollCheck, prePollCheck, processBatch, processExchange, removeExcessiveInProgressFiles, removeExcessiveInProgressFiles, setCustomProcessor, setEagerLimitMaxMessagesPerPoll, setOperations
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, setMaxMessagesPerPoll
afterPoll, beforePoll, doShutdown, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected void updateFileHeaders(org.apache.camel.component.file.GenericFile<EventfulFileWrapper> file, org.apache.camel.Message message)
protected boolean isMatched(org.apache.camel.component.file.GenericFile file, String doneFileName, List files)
isMatched
in class org.apache.camel.component.file.GenericFileConsumer<EventfulFileWrapper>
protected boolean pollDirectory(String fileName, List list, int depth)
pollDirectory
in class org.apache.camel.component.file.GenericFileConsumer<EventfulFileWrapper>
protected abstract boolean doPoll(@NotNull String sha1)
This work is licensed under a Creative Commons Attribution 4.0 International License.