|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.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<T>
public abstract class RemoteFileEndpoint<T>
Remote file endpoint.
Field Summary |
---|
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 | |
---|---|
RemoteFileEndpoint()
|
|
RemoteFileEndpoint(String uri,
RemoteFileComponent<T> component,
RemoteFileConfiguration configuration)
|
Method Summary | |
---|---|
protected void |
afterPropertiesSet()
Validates this endpoint if its configured properly. |
protected abstract RemoteFileConsumer<T> |
buildConsumer(org.apache.camel.Processor processor)
Remote File Endpoints, impl this method to create a custom consumer specific to their "protocol" etc. |
protected abstract org.apache.camel.component.file.GenericFileProducer<T> |
buildProducer()
Remote File Endpoints, impl this method to create a custom producer specific to their "protocol" etc. |
RemoteFileConsumer<T> |
createConsumer(org.apache.camel.Processor processor)
|
org.apache.camel.Exchange |
createExchange(org.apache.camel.component.file.GenericFile<T> file)
|
org.apache.camel.component.file.GenericFileProducer<T> |
createProducer()
|
abstract RemoteFileOperations<T> |
createRemoteFileOperations()
Creates the operations to be used by the consumer or producer. |
RemoteFileConfiguration |
getConfiguration()
|
char |
getFileSeparator()
|
int |
getMaximumReconnectAttempts()
|
protected Map<String,Object> |
getParamsAsMap()
|
long |
getReconnectDelay()
|
boolean |
isAbsolute(String name)
|
boolean |
isDisconnect()
|
boolean |
isDownload()
|
boolean |
isFastExistsCheck()
|
String |
remoteServerInformation()
Returns human readable server information for logging purpose |
void |
setDisconnect(boolean disconnect)
|
void |
setDownload(boolean download)
|
void |
setFastExistsCheck(boolean fastExistsCheck)
|
void |
setMaximumReconnectAttempts(int maximumReconnectAttempts)
|
void |
setReconnectDelay(long reconnectDelay)
|
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, getScheme, 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, 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, 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 |
Constructor Detail |
---|
public RemoteFileEndpoint()
public RemoteFileEndpoint(String uri, RemoteFileComponent<T> component, RemoteFileConfiguration configuration)
Method Detail |
---|
public RemoteFileConfiguration getConfiguration()
getConfiguration
in class org.apache.camel.component.file.GenericFileEndpoint<T>
public org.apache.camel.Exchange createExchange(org.apache.camel.component.file.GenericFile<T> file)
createExchange
in class org.apache.camel.component.file.GenericFileEndpoint<T>
public org.apache.camel.component.file.GenericFileProducer<T> createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
createProducer
in class org.apache.camel.component.file.GenericFileEndpoint<T>
Exception
public RemoteFileConsumer<T> createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
createConsumer
in class org.apache.camel.component.file.GenericFileEndpoint<T>
Exception
protected void afterPropertiesSet() throws Exception
Exception
- is thrown if endpoint is invalid configured for its mandatory optionsprotected Map<String,Object> getParamsAsMap()
getParamsAsMap
in class org.apache.camel.component.file.GenericFileEndpoint<T>
protected abstract RemoteFileConsumer<T> buildConsumer(org.apache.camel.Processor processor)
processor
- the processor
protected abstract org.apache.camel.component.file.GenericFileProducer<T> buildProducer()
public abstract RemoteFileOperations<T> createRemoteFileOperations() throws Exception
Exception
- is thrown if error creating operations.public String remoteServerInformation()
public char getFileSeparator()
getFileSeparator
in class org.apache.camel.component.file.GenericFileEndpoint<T>
public boolean isAbsolute(String name)
isAbsolute
in class org.apache.camel.component.file.GenericFileEndpoint<T>
public int getMaximumReconnectAttempts()
public void setMaximumReconnectAttempts(int maximumReconnectAttempts)
public long getReconnectDelay()
public void setReconnectDelay(long reconnectDelay)
public boolean isDisconnect()
public void setDisconnect(boolean disconnect)
public boolean isFastExistsCheck()
public void setFastExistsCheck(boolean fastExistsCheck)
public boolean isDownload()
public void setDownload(boolean download)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |