Package | Description |
---|---|
org.apache.camel.component.file |
The File Component for working with file systems.
|
org.apache.camel.component.file.strategy |
Strategies for the File Component.
|
Modifier and Type | Class and Description |
---|---|
class |
FileOperations
File operations for
File . |
Modifier and Type | Field and Description |
---|---|
protected GenericFileOperations<T> |
GenericFileConsumer.operations |
protected GenericFileOperations<T> |
GenericFileProducer.operations |
Modifier and Type | Method and Description |
---|---|
void |
GenericFileProcessStrategy.abort(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file)
Called when a begin is aborted, for example to release any resources which may have
been acquired during the
GenericFileProcessStrategy.begin(GenericFileOperations, GenericFileEndpoint, org.apache.camel.Exchange, GenericFile)
operation. |
boolean |
GenericFileExclusiveReadLockStrategy.acquireExclusiveReadLock(GenericFileOperations<T> operations,
GenericFile<T> file,
Exchange exchange)
Acquires exclusive read lock to the file.
|
boolean |
GenericFileProcessStrategy.begin(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file)
Called when work is about to begin on this file.
|
void |
GenericFileProcessStrategy.commit(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file)
Releases any file locks and possibly deletes or moves the file after
successful processing
|
protected FileConsumer |
FileEndpoint.newFileConsumer(Processor processor,
GenericFileOperations<File> operations)
Strategy to create a new
FileConsumer |
void |
GenericFileExclusiveReadLockStrategy.prepareOnStartup(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint)
Allows custom logic to be run on startup preparing the strategy, such as removing old lock files etc.
|
void |
GenericFileProcessStrategy.prepareOnStartup(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint)
Allows custom logic to be run on first poll preparing the strategy,
such as removing old lock files etc.
|
void |
GenericFileExclusiveReadLockStrategy.releaseExclusiveReadLockOnAbort(GenericFileOperations<T> operations,
GenericFile<T> file,
Exchange exchange)
Releases the exclusive read lock granted by the acquireExclusiveReadLock method due an abort operation (acquireExclusiveReadLock returned false).
|
void |
GenericFileExclusiveReadLockStrategy.releaseExclusiveReadLockOnCommit(GenericFileOperations<T> operations,
GenericFile<T> file,
Exchange exchange)
Releases the exclusive read lock granted by the acquireExclusiveReadLock method due a commit operation (Exchange processing succeeded)
|
void |
GenericFileExclusiveReadLockStrategy.releaseExclusiveReadLockOnRollback(GenericFileOperations<T> operations,
GenericFile<T> file,
Exchange exchange)
Releases the exclusive read lock granted by the acquireExclusiveReadLock method due a rollback operation (Exchange processing failed)
|
void |
GenericFileProcessStrategy.rollback(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file)
Releases any file locks and possibly deletes or moves the file after
unsuccessful processing
|
void |
GenericFileConsumer.setOperations(GenericFileOperations<T> operations)
Sets the operations to be used.
|
void |
GenericFileProducer.setOperations(GenericFileOperations<T> operations)
Sets the operations to be used.
|
Constructor and Description |
---|
FileConsumer(FileEndpoint endpoint,
Processor processor,
GenericFileOperations<File> operations) |
GenericFileConsumer(GenericFileEndpoint<T> endpoint,
Processor processor,
GenericFileOperations<T> operations) |
GenericFileOnCompletion(GenericFileEndpoint<T> endpoint,
GenericFileOperations<T> operations,
GenericFile<T> file,
String absoluteFileName) |
GenericFileProducer(GenericFileEndpoint<T> endpoint,
GenericFileOperations<T> operations) |
Modifier and Type | Method and Description |
---|---|
void |
GenericFileProcessStrategySupport.abort(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
boolean |
FileLockExclusiveReadLockStrategy.acquireExclusiveReadLock(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
boolean |
FileIdempotentRepositoryReadLockStrategy.acquireExclusiveReadLock(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
boolean |
FileRenameExclusiveReadLockStrategy.acquireExclusiveReadLock(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
boolean |
MarkerFileExclusiveReadLockStrategy.acquireExclusiveReadLock(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
boolean |
FileChangedExclusiveReadLockStrategy.acquireExclusiveReadLock(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
boolean |
GenericFileRenameExclusiveReadLockStrategy.acquireExclusiveReadLock(GenericFileOperations<T> operations,
GenericFile<T> file,
Exchange exchange) |
boolean |
GenericFileRenameProcessStrategy.begin(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
boolean |
GenericFileDeleteProcessStrategy.begin(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
boolean |
GenericFileProcessStrategySupport.begin(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
void |
GenericFileRenameProcessStrategy.commit(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
void |
GenericFileDeleteProcessStrategy.commit(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
void |
GenericFileProcessStrategySupport.commit(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
protected void |
FileLockExclusiveReadLockStrategy.doReleaseExclusiveReadLock(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
protected void |
MarkerFileExclusiveReadLockStrategy.doReleaseExclusiveReadLock(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
FileLockExclusiveReadLockStrategy.prepareOnStartup(GenericFileOperations<File> operations,
GenericFileEndpoint<File> endpoint) |
void |
FileIdempotentRepositoryReadLockStrategy.prepareOnStartup(GenericFileOperations<File> operations,
GenericFileEndpoint<File> endpoint) |
void |
MarkerFileExclusiveReadLockStrategy.prepareOnStartup(GenericFileOperations<File> operations,
GenericFileEndpoint<File> endpoint) |
void |
GenericFileProcessStrategySupport.prepareOnStartup(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint) |
void |
GenericFileRenameExclusiveReadLockStrategy.prepareOnStartup(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint) |
void |
FileIdempotentRepositoryReadLockStrategy.releaseExclusiveReadLockOnAbort(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
FileRenameExclusiveReadLockStrategy.releaseExclusiveReadLockOnAbort(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
MarkerFileExclusiveReadLockStrategy.releaseExclusiveReadLockOnAbort(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
GenericFileRenameExclusiveReadLockStrategy.releaseExclusiveReadLockOnAbort(GenericFileOperations<T> operations,
GenericFile<T> file,
Exchange exchange) |
void |
FileIdempotentRepositoryReadLockStrategy.releaseExclusiveReadLockOnCommit(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
FileRenameExclusiveReadLockStrategy.releaseExclusiveReadLockOnCommit(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
MarkerFileExclusiveReadLockStrategy.releaseExclusiveReadLockOnCommit(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
GenericFileRenameExclusiveReadLockStrategy.releaseExclusiveReadLockOnCommit(GenericFileOperations<T> operations,
GenericFile<T> file,
Exchange exchange) |
void |
FileIdempotentRepositoryReadLockStrategy.releaseExclusiveReadLockOnRollback(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
FileRenameExclusiveReadLockStrategy.releaseExclusiveReadLockOnRollback(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
MarkerFileExclusiveReadLockStrategy.releaseExclusiveReadLockOnRollback(GenericFileOperations<File> operations,
GenericFile<File> file,
Exchange exchange) |
void |
GenericFileRenameExclusiveReadLockStrategy.releaseExclusiveReadLockOnRollback(GenericFileOperations<T> operations,
GenericFile<T> file,
Exchange exchange) |
protected GenericFile<T> |
GenericFileProcessStrategySupport.renameFile(GenericFileOperations<T> operations,
GenericFile<T> from,
GenericFile<T> to) |
void |
GenericFileRenameProcessStrategy.rollback(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
void |
GenericFileDeleteProcessStrategy.rollback(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
void |
GenericFileProcessStrategySupport.rollback(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file) |
Apache Camel