@UriEndpoint(scheme="file",
title="File",
syntax="file:directoryName",
consumerClass=FileConsumer.class,
label="core,file")
public class FileEndpoint
extends GenericFileEndpoint<File>
allowNullBody, antExclude, antFilter, antInclude, autoCreate, bufferSize, charset, chmod, configuration, DEFAULT_IDEMPOTENT_CACHE_SIZE, DEFAULT_STRATEGYFACTORY_CLASS, delete, directoryMustExist, doneFileName, eagerDeleteTargetFile, eagerMaxMessagesPerPoll, exclude, exclusiveReadLockStrategy, fileExist, fileName, filter, flatten, idempotent, idempotentKey, idempotentRepository, include, inProgressRepository, keepLastModified, localWorkDirectory, log, maxDepth, maxMessagesPerPoll, minDepth, move, moveExisting, moveFailed, noop, preMove, processStrategy, readLock, readLockCheckInterval, readLockLoggingLevel, readLockMarkerFile, readLockMinAge, readLockMinLength, readLockTimeout, recursive, sortBy, sorter, startingDirectoryMustExist, tempFileName, tempPrefixshutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
FileEndpoint() |
FileEndpoint(String endpointUri,
Component component) |
| Modifier and Type | Method and Description |
|---|---|
FileConsumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
protected String |
createEndpointUri()
A factory method to lazily create the endpointUri if none is specified
|
Exchange |
createExchange(GenericFile<File> file) |
GenericFileProducer<File> |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
File |
getFile() |
char |
getFileSeparator() |
String |
getScheme() |
boolean |
isAbsolute(String name) |
boolean |
isCopyAndDeleteOnRenameFail() |
boolean |
isForceWrites() |
boolean |
isRenameUsingCopy() |
protected FileConsumer |
newFileConsumer(Processor processor,
GenericFileOperations<File> operations)
Strategy to create a new
FileConsumer |
void |
setCopyAndDeleteOnRenameFail(boolean copyAndDeleteOnRenameFail)
Whether to fallback and do a copy and delete file, in case the file could not be renamed directly.
|
void |
setFile(File file)
The starting directory
|
void |
setForceWrites(boolean forceWrites)
Whether to force syncing writes to the file system.
|
void |
setRenameUsingCopy(boolean renameUsingCopy)
Perform rename operations using a copy and delete strategy.
|
chmodPermissionsAreValid, configureExchange, configureMessage, configureMoveOrPreMoveExpression, createDoneFileName, createGenericFileStrategy, doStart, doStop, getAntExclude, getAntFilter, getAntInclude, getBufferSize, getCharset, getChmod, getConfiguration, getDoneFileName, getExchanges, getExclude, getExclusiveReadLockStrategy, getFileExist, getFileName, getFilter, getGeneratedFileName, getGenericFileProcessStrategy, getIdempotentKey, getIdempotentRepository, getInclude, getInProgressRepository, getLocalWorkDirectory, getMaxDepth, getMaxMessagesPerPoll, getMinDepth, getMove, getMoveExisting, getMoveFailed, getParamsAsMap, getPermissions, getPreMove, getProcessStrategy, getReadLock, getReadLockCheckInterval, getReadLockLoggingLevel, getReadLockMinAge, getReadLockMinLength, getReadLockTimeout, getSortBy, getSorter, getTempFileName, getTempPrefix, isAllowNullBody, isAutoCreate, isDelete, isDirectoryMustExist, isDoneFile, isEagerDeleteTargetFile, isEagerMaxMessagesPerPoll, isFlatten, isIdempotent, isIdempotentSet, isKeepLastModified, isNoop, isReadLockMarkerFile, isRecursive, isSingleton, isStartingDirectoryMustExist, setAllowNullBody, setAntExclude, setAntFilterCaseSensitive, setAntInclude, setAutoCreate, setBufferSize, setCharset, setChmod, setConfiguration, setDelete, setDirectoryMustExist, setDoneFileName, setEagerDeleteTargetFile, setEagerMaxMessagesPerPoll, setExclude, setExclusiveReadLockStrategy, setFileExist, setFileName, setFileName, setFilter, setFlatten, setIdempotent, setIdempotentKey, setIdempotentKey, setIdempotentRepository, setInclude, setInProgressRepository, setKeepLastModified, setLocalWorkDirectory, setMaxDepth, setMaxMessagesPerPoll, setMinDepth, setMove, setMove, setMoveExisting, setMoveExisting, setMoveFailed, setMoveFailed, setNoop, setPreMove, setPreMove, setProcessStrategy, setReadLock, setReadLockCheckInterval, setReadLockLoggingLevel, setReadLockMarkerFile, setReadLockMinAge, setReadLockMinLength, setReadLockTimeout, setRecursive, setSortBy, setSortBy, setSortBy, setSorter, setStartingDirectoryMustExist, setTempFileName, setTempFileName, setTempPrefixconfigurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelayconfigureConsumer, createEndpointConfiguration, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendclone, finalize, getClass, notify, notifyAll, wait, wait, waitconfigureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointConfiguration, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContextpublic FileConsumer createConsumer(Processor processor) throws Exception
EndpointcreateConsumer in interface EndpointcreateConsumer in class GenericFileEndpoint<File>processor - the given processorException - can be thrownpublic GenericFileProducer<File> createProducer() throws Exception
EndpointcreateProducer in interface EndpointcreateProducer in class GenericFileEndpoint<File>Exception - can be thrownpublic Exchange createExchange(GenericFile<File> file)
createExchange in class GenericFileEndpoint<File>protected FileConsumer newFileConsumer(Processor processor, GenericFileOperations<File> operations)
FileConsumerprocessor - the given processoroperations - file operationspublic File getFile()
public void setFile(File file)
public String getScheme()
getScheme in class GenericFileEndpoint<File>protected String createEndpointUri()
DefaultEndpointcreateEndpointUri in class DefaultEndpointpublic char getFileSeparator()
getFileSeparator in class GenericFileEndpoint<File>public boolean isAbsolute(String name)
isAbsolute in class GenericFileEndpoint<File>public boolean isCopyAndDeleteOnRenameFail()
public void setCopyAndDeleteOnRenameFail(boolean copyAndDeleteOnRenameFail)
public boolean isRenameUsingCopy()
public void setRenameUsingCopy(boolean renameUsingCopy)
public boolean isForceWrites()
public void setForceWrites(boolean forceWrites)
Apache Camel