@UriEndpoint(scheme="durable", title="Durable File Endpoint", syntax="durable:directoryName", consumerClass=AbstractDurableFileConsumer.class, label="codice,file") public class DurableFileEndpoint extends org.apache.camel.component.file.GenericFileEndpoint<EventfulFileWrapper>
allowNullBody, antExclude, antFilter, antFilterCaseSensitive, 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, onCompletionExceptionHandler, preMove, processStrategy, readLock, readLockCheckInterval, readLockDeleteOrphanLockFiles, readLockLoggingLevel, readLockMarkerFile, readLockMinAge, readLockMinLength, readLockRemoveOnCommit, readLockRemoveOnRollback, readLockTimeout, recursive, shuffle, sortBy, sorter, startingDirectoryMustExist, tempFileName, tempPrefix
Modifier and Type | Method and Description |
---|---|
org.apache.camel.component.file.GenericFileConsumer<EventfulFileWrapper> |
createConsumer(org.apache.camel.Processor processor) |
protected String |
createEndpointUri() |
org.apache.camel.Exchange |
createExchange(org.apache.camel.component.file.GenericFile file) |
org.apache.camel.component.file.GenericFileProducer<EventfulFileWrapper> |
createProducer() |
char |
getFileSeparator() |
String |
getScheme() |
boolean |
isAbsolute(String name) |
void |
setFile(File file) |
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, getOnCompletionExceptionHandler, getParamsAsMap, getPermissions, getPreMove, getProcessStrategy, getReadLock, getReadLockCheckInterval, getReadLockLoggingLevel, getReadLockMinAge, getReadLockMinLength, getReadLockTimeout, getSortBy, getSorter, getTempFileName, getTempPrefix, isAllowNullBody, isAntFilterCaseSensitive, isAutoCreate, isDelete, isDirectoryMustExist, isDoneFile, isEagerDeleteTargetFile, isEagerMaxMessagesPerPoll, isFlatten, isIdempotent, isIdempotentSet, isKeepLastModified, isNoop, isReadLockDeleteOrphanLockFiles, isReadLockMarkerFile, isReadLockRemoveOnCommit, isReadLockRemoveOnRollback, isRecursive, isShuffle, 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, setOnCompletionExceptionHandler, setPreMove, setPreMove, setProcessStrategy, setReadLock, setReadLockCheckInterval, setReadLockDeleteOrphanLockFiles, setReadLockLoggingLevel, setReadLockMarkerFile, setReadLockMinAge, setReadLockMinLength, setReadLockRemoveOnCommit, setReadLockRemoveOnRollback, setReadLockTimeout, setRecursive, setShuffle, setSortBy, setSortBy, setSortBy, setSorter, setStartingDirectoryMustExist, setTempFileName, setTempFileName, setTempPrefix
configurePollingConsumer, 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, setUseFixedDelay
configureConsumer, createEndpointConfiguration, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public org.apache.camel.component.file.GenericFileConsumer<EventfulFileWrapper> createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
createConsumer
in class org.apache.camel.component.file.GenericFileEndpoint<EventfulFileWrapper>
Exception
public org.apache.camel.component.file.GenericFileProducer<EventfulFileWrapper> createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
createProducer
in class org.apache.camel.component.file.GenericFileEndpoint<EventfulFileWrapper>
Exception
public org.apache.camel.Exchange createExchange(org.apache.camel.component.file.GenericFile file)
createExchange
in class org.apache.camel.component.file.GenericFileEndpoint<EventfulFileWrapper>
public String getScheme()
getScheme
in class org.apache.camel.component.file.GenericFileEndpoint<EventfulFileWrapper>
public char getFileSeparator()
getFileSeparator
in class org.apache.camel.component.file.GenericFileEndpoint<EventfulFileWrapper>
public boolean isAbsolute(String name)
isAbsolute
in class org.apache.camel.component.file.GenericFileEndpoint<EventfulFileWrapper>
protected String createEndpointUri()
createEndpointUri
in class org.apache.camel.impl.DefaultEndpoint
public void setFile(File file)
This work is licensed under a Creative Commons Attribution 4.0 International License.