public class GenericFileProducer<T> extends DefaultProducer
| Modifier and Type | Field and Description |
|---|---|
protected GenericFileEndpoint<T> |
endpoint |
protected org.slf4j.Logger |
log |
protected GenericFileOperations<T> |
operations |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Modifier | Constructor and Description |
|---|---|
protected |
GenericFileProducer(GenericFileEndpoint<T> endpoint,
GenericFileOperations<T> operations) |
| Modifier and Type | Method and Description |
|---|---|
String |
createFileName(Exchange exchange) |
String |
createTempFileName(Exchange exchange,
String fileName) |
protected void |
doStart()
Implementations override this method to support customized start/stop.
|
protected void |
doStop()
Implementations override this method to support customized start/stop.
|
String |
getFileSeparator() |
void |
handleFailedWrite(Exchange exchange,
Exception exception)
If we fail writing out a file, we will call this method.
|
String |
normalizePath(String name) |
void |
postWriteCheck()
Perform any actions that need to occur after we are done such as disconnecting.
|
void |
preWriteCheck()
Perform any actions that need to occur before we write such as connecting to an FTP server etc.
|
void |
process(Exchange exchange)
Processes the message exchange
|
protected void |
processExchange(Exchange exchange,
String target)
Perform the work to process the fileExchange
|
void |
setOperations(GenericFileOperations<T> operations)
Sets the operations to be used.
|
void |
writeFile(Exchange exchange,
String fileName) |
createExchange, createExchange, createExchange, getEndpoint, isSingleton, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendprotected final org.slf4j.Logger log
protected final GenericFileEndpoint<T> endpoint
protected GenericFileOperations<T> operations
protected GenericFileProducer(GenericFileEndpoint<T> endpoint, GenericFileOperations<T> operations)
public String getFileSeparator()
public void process(Exchange exchange) throws Exception
Processorexchange - the message exchangeException - if an internal processing error has occurred.public void setOperations(GenericFileOperations<T> operations)
operations - the operationsprotected void processExchange(Exchange exchange, String target) throws Exception
exchange - fileExchangetarget - the target filenameException - is thrown if some errorpublic void handleFailedWrite(Exchange exchange, Exception exception) throws Exception
Exceptionpublic void preWriteCheck()
throws Exception
Exceptionpublic void postWriteCheck()
public void writeFile(Exchange exchange, String fileName) throws GenericFileOperationFailedException
protected void doStart()
throws Exception
ServiceSupportServiceSupport.doStop() for more details.doStart in class DefaultProducerExceptionServiceSupport.doStop()protected void doStop()
throws Exception
ServiceSupportServiceSupport.doStop() method when
the service is being stopped. This method will also be invoked
if the service is still in uninitialized state (eg has not
been started). The method is always called to allow the service
to do custom logic when the service is being stopped, such as when
CamelContext is shutting down.doStop in class DefaultProducerExceptionServiceSupport.doStart()Apache Camel