org.mule.transport.ftp
Class FtpMessageRequester
java.lang.Object
org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageRequester
org.mule.transport.ftp.FtpMessageRequester
- All Implemented Interfaces:
- Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, Connectable, MessageRequester, MessageRequesting
public class FtpMessageRequester
- extends AbstractMessageRequester
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler |
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, doStart, doStop, getConnectEventId, getConnectionDescription, getConnector, getLifecycleState, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopping, passivate, setEndpoint, start, stop, toString, validate, validateConnection |
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
connector
protected final FtpConnector connector
FtpMessageRequester
public FtpMessageRequester(InboundEndpoint endpoint)
doDispose
protected void doDispose()
- Overrides:
doDispose
in class AbstractTransportMessageHandler
doConnect
protected void doConnect()
throws Exception
- Overrides:
doConnect
in class AbstractTransportMessageHandler
- Throws:
Exception
doDisconnect
protected void doDisconnect()
throws Exception
- Overrides:
doDisconnect
in class AbstractTransportMessageHandler
- Throws:
Exception
doRequest
protected MuleMessage doRequest(long timeout)
throws Exception
- Make a specific request to the underlying transport
- Specified by:
doRequest
in class AbstractMessageRequester
- Parameters:
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.
- Returns:
- The result of the request wrapped in a MuleMessage object.
null
will be
returned if no data was avaialable
- Throws:
Exception
- if the call to the underlying protocol cuases an exception
postProcess
protected void postProcess(org.apache.commons.net.ftp.FTPClient client,
org.apache.commons.net.ftp.FTPFile file,
MuleMessage message)
throws Exception
- Throws:
Exception
initializeMessageFactory
protected void initializeMessageFactory()
throws InitialisationException
- Description copied from class:
AbstractTransportMessageHandler
- Subclasses can override this method to create a custom
MuleMessageFactory
instead
of re-using the instance from the connector.
- Overrides:
initializeMessageFactory
in class AbstractTransportMessageHandler
- Throws:
InitialisationException
createMuleMessageFactory
protected FtpMuleMessageFactory createMuleMessageFactory(org.apache.commons.net.ftp.FTPClient client)
throws CreateException
- Throws:
CreateException
prepareFile
protected org.apache.commons.net.ftp.FTPFile prepareFile(org.apache.commons.net.ftp.FTPClient client,
org.apache.commons.net.ftp.FTPFile file)
throws IOException
- Throws:
IOException
findFileToProcess
protected org.apache.commons.net.ftp.FTPFile findFileToProcess(org.apache.commons.net.ftp.FTPClient client)
throws Exception
- Throws:
Exception
listFiles
protected org.apache.commons.net.ftp.FTPFile[] listFiles(org.apache.commons.net.ftp.FTPClient client)
throws IOException
- Throws:
IOException
getFilenameFilter
protected FilenameFilter getFilenameFilter()
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.