|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.camel.support.ServiceSupport org.apache.camel.impl.DefaultEndpoint org.apache.camel.impl.ScheduledPollEndpoint org.apache.camel.component.file.GenericFileEndpoint<T> org.apache.camel.component.file.remote.RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile> org.apache.camel.component.file.remote.FtpEndpoint<T>
@UriEndpoint(scheme="ftp", consumerClass=FtpConsumer.class) public class FtpEndpoint<T extends org.apache.commons.net.ftp.FTPFile>
FTP endpoint
Field Summary | |
---|---|
protected int |
dataTimeout
|
protected org.apache.commons.net.ftp.FTPClient |
ftpClient
|
protected org.apache.commons.net.ftp.FTPClientConfig |
ftpClientConfig
|
protected Map<String,Object> |
ftpClientConfigParameters
|
protected Map<String,Object> |
ftpClientParameters
|
protected int |
soTimeout
|
Fields inherited from class org.apache.camel.component.file.GenericFileEndpoint |
---|
allowNullBody, antFilter, autoCreate, bufferSize, charset, 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, readLockMinLength, readLockTimeout, recursive, sortBy, sorter, startingDirectoryMustExist, tempFileName, tempPrefix |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
FtpEndpoint()
|
|
FtpEndpoint(String uri,
RemoteFileComponent<org.apache.commons.net.ftp.FTPFile> component,
RemoteFileConfiguration configuration)
|
Method Summary | |
---|---|
protected RemoteFileConsumer<org.apache.commons.net.ftp.FTPFile> |
buildConsumer(org.apache.camel.Processor processor)
Remote File Endpoints, impl this method to create a custom consumer specific to their "protocol" etc. |
protected org.apache.camel.component.file.GenericFileProducer<org.apache.commons.net.ftp.FTPFile> |
buildProducer()
Remote File Endpoints, impl this method to create a custom producer specific to their "protocol" etc. |
protected org.apache.commons.net.ftp.FTPClient |
createFtpClient()
|
RemoteFileOperations<org.apache.commons.net.ftp.FTPFile> |
createRemoteFileOperations()
Creates the operations to be used by the consumer or producer. |
FtpConfiguration |
getConfiguration()
|
char |
getFileSeparator()
|
org.apache.commons.net.ftp.FTPClient |
getFtpClient()
|
org.apache.commons.net.ftp.FTPClientConfig |
getFtpClientConfig()
|
String |
getScheme()
|
int |
getSoTimeout()
|
void |
setConfiguration(FtpConfiguration configuration)
|
void |
setConfiguration(org.apache.camel.component.file.GenericFileConfiguration configuration)
|
void |
setFtpClient(org.apache.commons.net.ftp.FTPClient ftpClient)
|
void |
setFtpClientConfig(org.apache.commons.net.ftp.FTPClientConfig ftpClientConfig)
|
void |
setSoTimeout(int soTimeout)
Sets the soTimeout option. |
Methods inherited from class org.apache.camel.component.file.remote.RemoteFileEndpoint |
---|
afterPropertiesSet, createConsumer, createExchange, createProducer, getMaximumReconnectAttempts, getParamsAsMap, getReconnectDelay, isAbsolute, isDisconnect, isDownload, isFastExistsCheck, remoteServerInformation, setDisconnect, setDownload, setFastExistsCheck, setMaximumReconnectAttempts, setReconnectDelay |
Methods inherited from class org.apache.camel.component.file.GenericFileEndpoint |
---|
configureExchange, configureMessage, configureMoveOrPreMoveExpression, createDoneFileName, createGenericFileStrategy, doStart, doStop, getAntFilter, getBufferSize, getCharset, getDoneFileName, getExchanges, getExclude, getExclusiveReadLockStrategy, getFileExist, getFileName, getFilter, getGeneratedFileName, getGenericFileProcessStrategy, getIdempotentKey, getIdempotentRepository, getInclude, getInProgressRepository, getLocalWorkDirectory, getMaxDepth, getMaxMessagesPerPoll, getMinDepth, getMove, getMoveExisting, getMoveFailed, getPreMove, getProcessStrategy, getReadLock, getReadLockCheckInterval, getReadLockLoggingLevel, getReadLockMinLength, getReadLockTimeout, getSortBy, getSorter, getTempFileName, getTempPrefix, isAllowNullBody, isAutoCreate, isDelete, isDirectoryMustExist, isDoneFile, isEagerDeleteTargetFile, isEagerMaxMessagesPerPoll, isFlatten, isIdempotent, isIdempotentSet, isKeepLastModified, isNoop, isRecursive, isSingleton, isStartingDirectoryMustExist, setAllowNullBody, setAntExclude, setAntFilterCaseSensitive, setAntInclude, setAutoCreate, setBufferSize, setCharset, 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, setReadLockMinLength, setReadLockTimeout, setRecursive, setSortBy, setSortBy, setSortBy, setSorter, setStartingDirectoryMustExist, setTempFileName, setTempFileName, setTempPrefix |
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint |
---|
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
---|
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Endpoint |
---|
configureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointConfiguration, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContext |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Field Detail |
---|
protected org.apache.commons.net.ftp.FTPClient ftpClient
protected org.apache.commons.net.ftp.FTPClientConfig ftpClientConfig
protected Map<String,Object> ftpClientParameters
protected Map<String,Object> ftpClientConfigParameters
@UriParam protected int soTimeout
@UriParam protected int dataTimeout
Constructor Detail |
---|
public FtpEndpoint()
public FtpEndpoint(String uri, RemoteFileComponent<org.apache.commons.net.ftp.FTPFile> component, RemoteFileConfiguration configuration)
Method Detail |
---|
public String getScheme()
getScheme
in class org.apache.camel.component.file.GenericFileEndpoint<org.apache.commons.net.ftp.FTPFile>
protected RemoteFileConsumer<org.apache.commons.net.ftp.FTPFile> buildConsumer(org.apache.camel.Processor processor)
RemoteFileEndpoint
buildConsumer
in class RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile>
processor
- the processor
protected org.apache.camel.component.file.GenericFileProducer<org.apache.commons.net.ftp.FTPFile> buildProducer()
RemoteFileEndpoint
buildProducer
in class RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile>
public RemoteFileOperations<org.apache.commons.net.ftp.FTPFile> createRemoteFileOperations() throws Exception
RemoteFileEndpoint
createRemoteFileOperations
in class RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile>
Exception
- is thrown if error creating operations.protected org.apache.commons.net.ftp.FTPClient createFtpClient() throws Exception
Exception
public FtpConfiguration getConfiguration()
getConfiguration
in class RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile>
public void setConfiguration(org.apache.camel.component.file.GenericFileConfiguration configuration)
setConfiguration
in class org.apache.camel.component.file.GenericFileEndpoint<org.apache.commons.net.ftp.FTPFile>
public void setConfiguration(FtpConfiguration configuration)
public org.apache.commons.net.ftp.FTPClient getFtpClient()
public void setFtpClient(org.apache.commons.net.ftp.FTPClient ftpClient)
public org.apache.commons.net.ftp.FTPClientConfig getFtpClientConfig()
public void setFtpClientConfig(org.apache.commons.net.ftp.FTPClientConfig ftpClientConfig)
public int getSoTimeout()
public void setSoTimeout(int soTimeout)
public char getFileSeparator()
getFileSeparator
in class RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |