public class

ReadMessageSource

extends AbstractListeningMessageProcessor
implements Runnable FlowConstructAware MuleContextAware Startable Stoppable MessageSource
java.lang.Object
   ↳ org.mule.devkit.processor.ExpressionEvaluatorSupport
     ↳ org.mule.devkit.processor.DevkitBasedMessageProcessor
       ↳ org.mule.security.oauth.processor.AbstractListeningMessageProcessor
         ↳ org.mule.modules.ftps.sources.ReadMessageSource

Class Overview

ReadMessageSource wraps read(org.mule.api.callback.SourceCallback, java.lang.String, java.lang.String, java.lang.String, int, java.lang.String) method in FTPSConnector as a message source capable of generating Mule events. The POJO's method is invoked in its own thread.

Summary

[Expand]
Inherited Constants
From interface org.mule.api.lifecycle.Disposable
From interface org.mule.api.lifecycle.Initialisable
From interface org.mule.api.lifecycle.Startable
From interface org.mule.api.lifecycle.Stoppable
Fields
protected String _fileNameType
protected String _filePathType
protected String _moveToDirType
protected int _pollingPeriodType
protected String _specIdType
protected Object fileName
protected Object filePath
protected Object moveToDir
protected Object pollingPeriod
protected Object specId
private Thread thread Thread under which this message source will execute
[Expand]
Inherited Fields
From class org.mule.security.oauth.processor.AbstractListeningMessageProcessor
From class org.mule.devkit.processor.DevkitBasedMessageProcessor
Public Constructors
ReadMessageSource(String operationName)
Public Methods
void initialise()
Obtains the expression manager from the Mule context and initialises the connector.
void run()
Implementation run() that will invoke the method on the pojo that this message source wraps.
void setFileName(Object value)
Sets fileName
void setFilePath(Object value)
Sets filePath
void setMoveToDir(Object value)
Sets moveToDir
void setPollingPeriod(Object value)
Sets pollingPeriod
void setSpecId(Object value)
Sets specId
void start()
Method to be called when Mule instance gets started.
void stop()
Method to be called when Mule instance gets stopped.
[Expand]
Inherited Methods
From class org.mule.security.oauth.processor.AbstractListeningMessageProcessor
From class org.mule.devkit.processor.DevkitBasedMessageProcessor
From class org.mule.devkit.processor.ExpressionEvaluatorSupport
From class java.lang.Object
From interface java.lang.Runnable
From interface org.mule.api.callback.SourceCallback
From interface org.mule.api.construct.FlowConstructAware
From interface org.mule.api.context.MuleContextAware
From interface org.mule.api.lifecycle.Disposable
From interface org.mule.api.lifecycle.Initialisable
From interface org.mule.api.lifecycle.Startable
From interface org.mule.api.lifecycle.Stoppable
From interface org.mule.api.processor.MessageProcessorContainer
From interface org.mule.api.source.MessageSource

Fields

protected String _fileNameType

protected String _filePathType

protected String _moveToDirType

protected int _pollingPeriodType

protected String _specIdType

protected Object fileName

protected Object filePath

protected Object moveToDir

protected Object pollingPeriod

protected Object specId

private Thread thread

Thread under which this message source will execute

Public Constructors

public ReadMessageSource (String operationName)

Parameters
operationName

Public Methods

public void initialise ()

Obtains the expression manager from the Mule context and initialises the connector. If a target object has not been set already it will search the Mule registry for a default one.

Throws
InitialisationException

public void run ()

Implementation run() that will invoke the method on the pojo that this message source wraps.

public void setFileName (Object value)

Sets fileName

Parameters
value Value to set

public void setFilePath (Object value)

Sets filePath

Parameters
value Value to set

public void setMoveToDir (Object value)

Sets moveToDir

Parameters
value Value to set

public void setPollingPeriod (Object value)

Sets pollingPeriod

Parameters
value Value to set

public void setSpecId (Object value)

Sets specId

Parameters
value Value to set

public void start ()

Method to be called when Mule instance gets started.

Throws
MuleException

public void stop ()

Method to be called when Mule instance gets stopped.

Throws
MuleException