|
||||||||||
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.DefaultConsumer
org.apache.camel.impl.ScheduledPollConsumer
org.apache.camel.impl.ScheduledBatchPollingConsumer
org.apache.camel.component.file.GenericFileConsumer<T>
org.apache.camel.component.file.remote.RemoteFileConsumer<T>
public abstract class RemoteFileConsumer<T>
Base class for remote file consumers.
Field Summary | |
---|---|
protected boolean |
loggedIn
|
protected boolean |
loggedInWarning
|
Fields inherited from class org.apache.camel.component.file.GenericFileConsumer |
---|
customProcessor, eagerLimitMaxMessagesPerPoll, endpoint, fileExpressionResult, log, operations, pendingExchanges, prepareOnStartup, shutdownRunningTask |
Fields inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer |
---|
maxMessagesPerPoll |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
RemoteFileConsumer(RemoteFileEndpoint<T> endpoint,
org.apache.camel.Processor processor,
RemoteFileOperations<T> operations)
|
Method Summary | |
---|---|
protected void |
connectIfNecessary()
|
protected void |
disconnect()
|
protected void |
doStop()
|
RemoteFileEndpoint<T> |
getEndpoint()
|
protected RemoteFileOperations<T> |
getOperations()
|
protected boolean |
isRetrieveFile()
|
protected void |
postPollCheck()
|
protected boolean |
prePollCheck()
|
protected boolean |
processExchange(org.apache.camel.Exchange exchange)
|
protected void |
recoverableConnectIfNecessary()
|
protected String |
remoteServer()
Returns human readable server information for logging purpose |
Methods inherited from class org.apache.camel.component.file.GenericFileConsumer |
---|
canPollMoreFiles, customProcessExchange, doStart, evaluateFileExpression, getCustomProcessor, ignoreCannotRetrieveFile, isEagerLimitMaxMessagesPerPoll, isInProgress, isMatched, isMatched, isValidFile, poll, pollDirectory, processBatch, removeExcessiveInProgressFiles, setCustomProcessor, setEagerLimitMaxMessagesPerPoll, setOperations |
Methods inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer |
---|
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, setMaxMessagesPerPoll |
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer |
---|
afterPoll, beforePoll, doShutdown, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler |
Methods inherited from class org.apache.camel.impl.DefaultConsumer |
---|
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Methods inherited from interface org.apache.camel.SuspendableService |
---|
isSuspended, resume, suspend |
Field Detail |
---|
protected boolean loggedIn
protected boolean loggedInWarning
Constructor Detail |
---|
public RemoteFileConsumer(RemoteFileEndpoint<T> endpoint, org.apache.camel.Processor processor, RemoteFileOperations<T> operations)
Method Detail |
---|
public RemoteFileEndpoint<T> getEndpoint()
getEndpoint
in interface org.apache.camel.Consumer
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
protected RemoteFileOperations<T> getOperations()
protected boolean prePollCheck() throws Exception
prePollCheck
in class org.apache.camel.component.file.GenericFileConsumer<T>
Exception
protected void postPollCheck()
postPollCheck
in class org.apache.camel.component.file.GenericFileConsumer<T>
protected boolean processExchange(org.apache.camel.Exchange exchange)
processExchange
in class org.apache.camel.component.file.GenericFileConsumer<T>
protected boolean isRetrieveFile()
isRetrieveFile
in class org.apache.camel.component.file.GenericFileConsumer<T>
protected void doStop() throws Exception
doStop
in class org.apache.camel.component.file.GenericFileConsumer<T>
Exception
protected void disconnect()
protected void recoverableConnectIfNecessary() throws Exception
Exception
protected void connectIfNecessary() throws IOException
IOException
protected String remoteServer()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |