public abstract class GenericFileProcessStrategySupport<T> extends Object implements GenericFileProcessStrategy<T>
GenericFileProcessStrategy.| Modifier and Type | Field and Description |
|---|---|
protected GenericFileExclusiveReadLockStrategy<T> |
exclusiveReadLockStrategy |
protected org.slf4j.Logger |
log |
| Constructor and Description |
|---|
GenericFileProcessStrategySupport() |
| Modifier and Type | Method and Description |
|---|---|
void |
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 |
begin(GenericFileOperations<T> operations,
GenericFileEndpoint<T> endpoint,
Exchange exchange,
GenericFile<T> file)
Called when work is about to begin on this file.
|
void |
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 void |
deleteLocalWorkFile(Exchange exchange) |
GenericFileExclusiveReadLockStrategy<T> |
getExclusiveReadLockStrategy() |
void |
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.
|
protected GenericFile<T> |
renameFile(GenericFileOperations<T> operations,
GenericFile<T> from,
GenericFile<T> to) |
void |
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 |
setExclusiveReadLockStrategy(GenericFileExclusiveReadLockStrategy<T> exclusiveReadLockStrategy) |
protected final org.slf4j.Logger log
protected GenericFileExclusiveReadLockStrategy<T> exclusiveReadLockStrategy
public GenericFileProcessStrategySupport()
public void prepareOnStartup(GenericFileOperations<T> operations, GenericFileEndpoint<T> endpoint) throws Exception
GenericFileProcessStrategyprepareOnStartup in interface GenericFileProcessStrategy<T>operations - file operationsendpoint - the endpointException - can be thrown in case of errors which causes poll to failpublic boolean begin(GenericFileOperations<T> operations, GenericFileEndpoint<T> endpoint, Exchange exchange, GenericFile<T> file) throws Exception
GenericFileProcessStrategybegin in interface GenericFileProcessStrategy<T>operations - file operationsendpoint - the endpointexchange - the exchangefile - the fileException - can be thrown in case of errorspublic void abort(GenericFileOperations<T> operations, GenericFileEndpoint<T> endpoint, Exchange exchange, GenericFile<T> file) throws Exception
GenericFileProcessStrategyGenericFileProcessStrategy.begin(GenericFileOperations, GenericFileEndpoint, org.apache.camel.Exchange, GenericFile)
operation.abort in interface GenericFileProcessStrategy<T>operations - file operationsendpoint - the endpointexchange - the exchangefile - the fileException - can be thrown in case of errorspublic void commit(GenericFileOperations<T> operations, GenericFileEndpoint<T> endpoint, Exchange exchange, GenericFile<T> file) throws Exception
GenericFileProcessStrategycommit in interface GenericFileProcessStrategy<T>operations - file operationsendpoint - the endpointexchange - the exchangefile - the fileException - can be thrown in case of errorspublic void rollback(GenericFileOperations<T> operations, GenericFileEndpoint<T> endpoint, Exchange exchange, GenericFile<T> file) throws Exception
GenericFileProcessStrategyrollback in interface GenericFileProcessStrategy<T>operations - file operationsendpoint - the endpointexchange - the exchangefile - the fileException - can be thrown in case of errorspublic GenericFileExclusiveReadLockStrategy<T> getExclusiveReadLockStrategy()
public void setExclusiveReadLockStrategy(GenericFileExclusiveReadLockStrategy<T> exclusiveReadLockStrategy)
protected GenericFile<T> renameFile(GenericFileOperations<T> operations, GenericFile<T> from, GenericFile<T> to) throws IOException
IOExceptionprotected void deleteLocalWorkFile(Exchange exchange)
Apache Camel