|
| |
|
| java.lang.Object
 org.mule.transport.AbstractConnector
org.mule.transport.ftp.FtpConnector
| DEFAULT_FTP_CONNECTION_FACTORY_CLASS | | final public static String DEFAULT_FTP_CONNECTION_FACTORY_CLASS(Code) | | TODO it makes sense to have a type-safe adapter for FTP specifically, but without
Java 5's covariant return types the benefits are diminished. Keeping it simple for now.
|
| DEFAULT_POLLING_FREQUENCY | | final public static int DEFAULT_POLLING_FREQUENCY(Code) | | |
| PROPERTY_BINARY_TRANSFER | | final public static String PROPERTY_BINARY_TRANSFER(Code) | | |
| PROPERTY_FILENAME | | final public static String PROPERTY_FILENAME(Code) | | |
| PROPERTY_OUTPUT_PATTERN | | final public static String PROPERTY_OUTPUT_PATTERN(Code) | | |
| PROPERTY_PASSIVE_MODE | | final public static String PROPERTY_PASSIVE_MODE(Code) | | |
| PROPERTY_POLLING_FREQUENCY | | final public static String PROPERTY_POLLING_FREQUENCY(Code) | | |
| createFtpClient | | protected FTPClient createFtpClient(ImmutableEndpoint endpoint) throws Exception(Code) | | Creates a new FTPClient that logs in and changes the working directory using the data
provided in endpoint.
|
| doDispose | | protected void doDispose()(Code) | | |
| enterActiveOrPassiveMode | | public void enterActiveOrPassiveMode(FTPClient client, ImmutableEndpoint endpoint)(Code) | | Passive mode is OFF by default. The value is taken from the connector
settings. In case there are any overriding properties set on the endpoint,
those will be used.
See Also: FtpConnector.setPassive(boolean) |
| getConnectionFactoryClass | | public String getConnectionFactoryClass()(Code) | | Getter for property 'connectionFactoryClass'.
Value for property 'connectionFactoryClass'. |
| getOutputPattern | | public String getOutputPattern()(Code) | | Returns the outputPattern. |
| getOutputStream | | public OutputStream getOutputStream(ImmutableEndpoint endpoint, MuleMessage message) throws MuleException(Code) | | Well get the output stream (if any) for this type of transport. Typically this
will be called only when Streaming is being used on an outbound endpoint
Parameters:
endpoint - the endpoint that releates to this Dispatcher
Parameters:
message - the current message being processed the output stream to use for this request or null if the transportdoes not support streaming
throws:
org.mule.api.MuleException - |
| getPollingFrequency | | public long getPollingFrequency()(Code) | | Returns the pollingFrequency. |
| isBinary | | public boolean isBinary()(Code) | | Getter for FTP transfer type.
true if using FTP binary type |
| isPassive | | public boolean isPassive()(Code) | | Getter for FTP passive mode.
true if using FTP passive mode |
| isValidateConnections | | public boolean isValidateConnections()(Code) | | Whether to test FTP connection on each take from pool.
|
| setBinary | | public void setBinary(boolean binary)(Code) | | Setter for FTP transfer type.
Parameters:
binary - binary type flag |
| setConnectionFactoryClass | | public void setConnectionFactoryClass(String connectionFactoryClass)(Code) | | Setter for property 'connectionFactoryClass'. Should be an instance of
FtpConnectionFactory .
Parameters:
connectionFactoryClass - Value to set for property 'connectionFactoryClass'. |
| setFilenameParser | | public void setFilenameParser(FilenameParser filenameParser)(Code) | |
Parameters:
filenameParser - The filenameParser to set. |
| setOutputPattern | | public void setOutputPattern(String outputPattern)(Code) | |
Parameters:
outputPattern - The outputPattern to set. |
| setPassive | | public void setPassive(boolean passive)(Code) | | Setter for FTP passive mode.
Parameters:
passive - passive mode flag |
| setPollingFrequency | | public void setPollingFrequency(long pollingFrequency)(Code) | |
Parameters:
pollingFrequency - The pollingFrequency to set. |
| setValidateConnections | | public void setValidateConnections(boolean validateConnections)(Code) | | Whether to test FTP connection on each take from pool. This takes care of a
failed (or restarted) FTP server at the expense of an additional NOOP command
packet being sent, but increases overall availability. Disable to gain
slight performance gain or if you are absolutely sure of the FTP server
availability. The default value is true
|
| setupFileType | | public void setupFileType(FTPClient client, ImmutableEndpoint endpoint) throws Exception(Code) | | Transfer type is BINARY by default. The value is taken from the connector
settings. In case there are any overriding properties set on the endpoint,
those will be used. The alternative type is ASCII.
See Also: FtpConnector.setBinary(boolean) |
| Methods inherited from org.mule.transport.AbstractConnector | protected void checkDisposed() throws DisposeException(Code)(Java Doc)
public void connect() throws Exception(Code)(Java Doc)
protected MessageReceiver createReceiver(Service service, InboundEndpoint endpoint) throws Exception(Code)(Java Doc)
public void destroyReceiver(MessageReceiver receiver, InboundEndpoint endpoint) throws Exception(Code)(Java Doc)
public void disconnect() throws Exception(Code)(Java Doc)
public void dispatch(OutboundEndpoint endpoint, MuleEvent event) throws DispatchException(Code)(Java Doc)
final public synchronized void dispose()(Code)(Java Doc)
protected void disposeDispatchers()(Code)(Java Doc)
protected void disposeReceivers()(Code)(Java Doc)
protected void disposeRequesters()(Code)(Java Doc)
protected void disposeWorkManagers()(Code)(Java Doc)
abstract protected void doConnect() throws Exception(Code)(Java Doc)
abstract protected void doDisconnect() throws Exception(Code)(Java Doc)
abstract protected void doDispose()(Code)(Java Doc)
abstract protected void doInitialise() throws InitialisationException(Code)(Java Doc)
abstract protected void doStart() throws MuleException(Code)(Java Doc)
abstract protected void doStop() throws MuleException(Code)(Java Doc)
public void exceptionThrown(Exception e)(Code)(Java Doc)
public void fireNotification(ServerNotification notification)(Code)(Java Doc)
protected String getConnectEventId()(Code)(Java Doc)
public String getConnectionDescription()(Code)(Java Doc)
public ConnectionStrategy getConnectionStrategy()(Code)(Java Doc)
public List getDefaultInboundTransformers()(Code)(Java Doc)
public List getDefaultOutboundTransformers()(Code)(Java Doc)
public List getDefaultResponseTransformers()(Code)(Java Doc)
public MessageDispatcherFactory getDispatcherFactory()(Code)(Java Doc)
public ThreadingProfile getDispatcherThreadingProfile()(Code)(Java Doc)
protected WorkManager getDispatcherWorkManager() throws MuleException(Code)(Java Doc)
public ExceptionListener getExceptionListener()(Code)(Java Doc)
public int getMaxDispatchersActive()(Code)(Java Doc)
public int getMaxRequestersActive()(Code)(Java Doc)
public MessageAdapter getMessageAdapter(Object message) throws MessagingException(Code)(Java Doc)
public MuleContext getMuleContext()(Code)(Java Doc)
public String getName()(Code)(Java Doc)
public int getNumberOfConcurrentTransactedReceivers()(Code)(Java Doc)
public OutputStream getOutputStream(OutboundEndpoint endpoint, MuleMessage message) throws MuleException(Code)(Java Doc)
public MessageReceiver getReceiver(Service service, InboundEndpoint endpoint)(Code)(Java Doc)
protected Object getReceiverKey(Service service, InboundEndpoint endpoint)(Code)(Java Doc)
public ThreadingProfile getReceiverThreadingProfile()(Code)(Java Doc)
protected WorkManager getReceiverWorkManager(String receiverName) throws MuleException(Code)(Java Doc)
public Map getReceivers()(Code)(Java Doc)
public MessageReceiver[] getReceivers(String wildcardExpression)(Code)(Java Doc)
public ReplyToHandler getReplyToHandler()(Code)(Java Doc)
public MessageRequesterFactory getRequesterFactory()(Code)(Java Doc)
public ThreadingProfile getRequesterThreadingProfile()(Code)(Java Doc)
protected WorkManager getRequesterWorkManager() throws MuleException(Code)(Java Doc)
public ScheduledExecutorService getScheduler()(Code)(Java Doc)
protected TransportServiceDescriptor getServiceDescriptor()(Code)(Java Doc)
public Map getServiceOverrides()(Code)(Java Doc)
public SessionHandler getSessionHandler()(Code)(Java Doc)
public List getSupportedProtocols()(Code)(Java Doc)
public void handleException(Exception exception)(Code)(Java Doc)
protected void handleWorkException(WorkEvent event, String type)(Code)(Java Doc)
protected synchronized void initFromServiceDescriptor() throws InitialisationException(Code)(Java Doc)
protected void initWorkManagers() throws MuleException(Code)(Java Doc)
final public synchronized LifecycleTransitionResult initialise() throws InitialisationException(Code)(Java Doc)
public void initialiseFromUrl(EndpointURI endpointUri) throws InitialisationException(Code)(Java Doc)
final public boolean isConnected()(Code)(Java Doc)
public boolean isCreateMultipleTransactedReceivers()(Code)(Java Doc)
public boolean isDisposed()(Code)(Java Doc)
public boolean isDisposing()(Code)(Java Doc)
public boolean isEnableMessageEvents()(Code)(Java Doc)
public boolean isRemoteSyncEnabled()(Code)(Java Doc)
public boolean isStarted()(Code)(Java Doc)
public boolean isSyncEnabled(String protocol)(Code)(Java Doc)
public MessageReceiver lookupReceiver(String key)(Code)(Java Doc)
public MessageReceiver registerListener(Service service, InboundEndpoint endpoint) throws Exception(Code)(Java Doc)
public void registerSupportedProtocol(String protocol)(Code)(Java Doc)
protected void registerSupportedProtocolWithoutPrefix(String protocol)(Code)(Java Doc)
public MuleMessage request(String uri, long timeout) throws Exception(Code)(Java Doc)
public MuleMessage request(InboundEndpoint endpoint, long timeout) throws Exception(Code)(Java Doc)
public MuleMessage send(OutboundEndpoint endpoint, MuleEvent event) throws DispatchException(Code)(Java Doc)
public void setConnectionStrategy(ConnectionStrategy connectionStrategy)(Code)(Java Doc)
public void setCreateMultipleTransactedReceivers(boolean createMultipleTransactedReceivers)(Code)(Java Doc)
public void setDispatcherFactory(MessageDispatcherFactory dispatcherFactory)(Code)(Java Doc)
public void setDispatcherThreadingProfile(ThreadingProfile dispatcherThreadingProfile)(Code)(Java Doc)
public void setDynamicNotification(boolean dynamic)(Code)(Java Doc)
public void setExceptionListener(ExceptionListener listener)(Code)(Java Doc)
public void setMaxDispatchersActive(int maxActive)(Code)(Java Doc)
public void setMaxRequestersActive(int maxActive)(Code)(Java Doc)
public void setMuleContext(MuleContext context)(Code)(Java Doc)
public void setName(String newName)(Code)(Java Doc)
public void setNumberOfConcurrentTransactedReceivers(int count)(Code)(Java Doc)
public void setReceiverThreadingProfile(ThreadingProfile receiverThreadingProfile)(Code)(Java Doc)
public void setRequesterFactory(MessageRequesterFactory requesterFactory)(Code)(Java Doc)
public void setRequesterThreadingProfile(ThreadingProfile requesterThreadingProfile)(Code)(Java Doc)
public void setServiceOverrides(Map serviceOverrides)(Code)(Java Doc)
public void setSessionHandler(SessionHandler sessionHandler)(Code)(Java Doc)
public void setSupportedProtocols(List supportedProtocols)(Code)(Java Doc)
protected void setupDispatchReturn(OutboundEndpoint endpoint, MessageDispatcher dispatcher, MuleMessage result)(Code)(Java Doc)
protected void setupRequestReturn(InboundEndpoint endpoint, MessageRequester requester, MuleMessage result)(Code)(Java Doc)
final public synchronized LifecycleTransitionResult start() throws MuleException(Code)(Java Doc)
final public synchronized LifecycleTransitionResult stop() throws MuleException(Code)(Java Doc)
public boolean supportsProtocol(String protocol)(Code)(Java Doc)
public String toString()(Code)(Java Doc)
final public void unregisterListener(Service service, InboundEndpoint endpoint) throws Exception(Code)(Java Doc)
public void unregisterSupportedProtocol(String protocol)(Code)(Java Doc)
protected void updateCachedNotificationHandler()(Code)(Java Doc)
public void workAccepted(WorkEvent event)(Code)(Java Doc)
public void workCompleted(WorkEvent event)(Code)(Java Doc)
public void workRejected(WorkEvent event)(Code)(Java Doc)
public void workStarted(WorkEvent event)(Code)(Java Doc)
|
|
|
|