public class FtpMessageRequester extends AbstractMessageRequester
Modifier and Type | Field and Description |
---|---|
protected FtpConnector |
connector |
connected, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
REQUEST_NO_WAIT, REQUEST_WAIT_INDEFINITELY
Constructor and Description |
---|
FtpMessageRequester(InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected FtpMuleMessageFactory |
createMuleMessageFactory(org.apache.commons.net.ftp.FTPClient client) |
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected MuleMessage |
doRequest(long timeout)
Make a specific request to the underlying transport
|
protected org.apache.commons.net.ftp.FTPFile |
findFileToProcess(org.apache.commons.net.ftp.FTPClient client) |
protected FilenameFilter |
getFilenameFilter() |
protected void |
initializeMessageFactory()
Subclasses can override this method to create a custom
MuleMessageFactory instead
of re-using the instance from the connector. |
protected boolean |
isValid(org.apache.commons.net.ftp.FTPFile file,
FilenameFilter filenameFilter) |
protected org.apache.commons.net.ftp.FTPFile[] |
listFiles(org.apache.commons.net.ftp.FTPClient client) |
protected void |
postProcess(org.apache.commons.net.ftp.FTPClient client,
org.apache.commons.net.ftp.FTPFile file,
MuleMessage message) |
protected org.apache.commons.net.ftp.FTPFile |
prepareFile(org.apache.commons.net.ftp.FTPClient client,
org.apache.commons.net.ftp.FTPFile file) |
applyInboundTransformers, createLifecycleManager, getEndpoint, getRequesterName, getWorkManager, initialise, request
activate, connect, connectHandler, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, doStart, doStartHandler, doStop, getConnectEventId, getConnectionDescription, getConnector, getLifecycleState, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, toString, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
activate, createMuleMessage, createMuleMessage, getConnector, passivate, validate
connect, disconnect, getConnectionDescription, isConnected, validateConnection
dispose
getLifecycleState
protected final FtpConnector connector
public FtpMessageRequester(InboundEndpoint endpoint)
protected void doDispose()
doDispose
in class AbstractTransportMessageHandler
protected void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
Exception
protected MuleMessage doRequest(long timeout) throws Exception
doRequest
in class AbstractMessageRequester
timeout
- The maximum time the operation should block before returning.
The call should return immediately if there is data available. If
no data becomes available before the timeout elapses, null will be
returned.null
will be
returned if no data was avaialableException
- if the call to the underlying protocol cuases an exceptionprotected void postProcess(org.apache.commons.net.ftp.FTPClient client, org.apache.commons.net.ftp.FTPFile file, MuleMessage message) throws Exception
Exception
protected void initializeMessageFactory() throws InitialisationException
AbstractTransportMessageHandler
MuleMessageFactory
instead
of re-using the instance from the connector.initializeMessageFactory
in class AbstractTransportMessageHandler
InitialisationException
protected FtpMuleMessageFactory createMuleMessageFactory(org.apache.commons.net.ftp.FTPClient client) throws CreateException
CreateException
protected org.apache.commons.net.ftp.FTPFile prepareFile(org.apache.commons.net.ftp.FTPClient client, org.apache.commons.net.ftp.FTPFile file) throws IOException
IOException
protected org.apache.commons.net.ftp.FTPFile findFileToProcess(org.apache.commons.net.ftp.FTPClient client) throws Exception
Exception
protected boolean isValid(org.apache.commons.net.ftp.FTPFile file, FilenameFilter filenameFilter)
protected org.apache.commons.net.ftp.FTPFile[] listFiles(org.apache.commons.net.ftp.FTPClient client) throws IOException
IOException
protected FilenameFilter getFilenameFilter()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.