public class FileConsumer extends GenericFileConsumer<File>
customProcessor, eagerLimitMaxMessagesPerPoll, endpoint, fileExpressionResult, log, operations, pendingExchanges, prepareOnStartup, shutdownRunningTaskmaxMessagesPerPollshutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
FileConsumer(FileEndpoint endpoint,
Processor processor,
GenericFileOperations<File> operations) |
| Modifier and Type | Method and Description |
|---|---|
static GenericFile<File> |
asGenericFile(String endpointPath,
File file,
String charset)
Deprecated.
|
static GenericFile<File> |
asGenericFile(String endpointPath,
File file,
String charset,
boolean probeContentType)
Creates a new GenericFile
|
FileEndpoint |
getEndpoint()
Gets the endpoint associated with an object.
|
protected boolean |
isMatched(GenericFile<File> file,
String doneFileName,
List<File> files)
Strategy to perform file matching based on endpoint configuration in terms of done file name.
|
protected boolean |
pollDirectory(String fileName,
List<GenericFile<File>> fileList,
int depth)
Polls the given directory for files to process
|
protected void |
updateFileHeaders(GenericFile<File> file,
Message message)
Updates the information on
Message after we have acquired read-lock and
can begin process the file. |
afterPoll, beforePoll, canPollMoreFiles, customProcessExchange, doStart, doStop, evaluateFileExpression, getCustomProcessor, ignoreCannotRetrieveFile, isEagerLimitMaxMessagesPerPoll, isInProgress, isMatched, isRetrieveFile, isValidFile, onInit, poll, postPollCheck, prePollCheck, processBatch, processExchange, removeExcessiveInProgressFiles, removeExcessiveInProgressFiles, setCustomProcessor, setEagerLimitMaxMessagesPerPoll, setOperationsdeferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, setMaxMessagesPerPolldoShutdown, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startSchedulercreateUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toStringdoResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic FileConsumer(FileEndpoint endpoint, Processor processor, GenericFileOperations<File> operations)
protected boolean pollDirectory(String fileName, List<GenericFile<File>> fileList, int depth)
GenericFileConsumerpollDirectory in class GenericFileConsumer<File>fileName - current directory or filefileList - current list of files gathereddepth - the current depth of the directory (will start from 0)protected boolean isMatched(GenericFile<File> file, String doneFileName, List<File> files)
GenericFileConsumerisMatched in class GenericFileConsumer<File>file - the filedoneFileName - the done file name (without any paths)files - files in the directory@Deprecated public static GenericFile<File> asGenericFile(String endpointPath, File file, String charset)
asGenericFile(String, File, String, boolean)endpointPath - the starting directory the endpoint was configured withfile - the source filepublic static GenericFile<File> asGenericFile(String endpointPath, File file, String charset, boolean probeContentType)
endpointPath - the starting directory the endpoint was configured withfile - the source fileprobeContentType - whether to probe the content type of the file or notprotected void updateFileHeaders(GenericFile<File> file, Message message)
GenericFileConsumerMessage after we have acquired read-lock and
can begin process the file.updateFileHeaders in class GenericFileConsumer<File>file - the filemessage - the Camel message to update its headerspublic FileEndpoint getEndpoint()
EndpointAwareProducer
or for consuming from for components like Consumer or RoutegetEndpoint in interface EndpointAwaregetEndpoint in class DefaultConsumerApache Camel