public class

ReceiveMessagesMessageSource

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.sqs.sources.ReceiveMessagesMessageSource

Class Overview

ReceiveMessagesMessageSource wraps receiveMessages(org.mule.api.callback.SourceCallback, java.lang.Integer, java.lang.Boolean, java.lang.Integer, java.lang.String) method in SQSConnector 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 Integer _numberOfMessagesType
protected Boolean _preserveMessagesType
protected String _queueUrlType
protected Integer _visibilityTimeoutType
protected Object numberOfMessages
static Long pollingPeriod Polling Period for SourceStrategy.POLLING
protected Object preserveMessages
protected Object queueUrl
private Thread thread Thread under which this message source will execute
protected Object visibilityTimeout
[Expand]
Inherited Fields
From class org.mule.security.oauth.processor.AbstractListeningMessageProcessor
From class org.mule.devkit.processor.DevkitBasedMessageProcessor
Public Constructors
ReceiveMessagesMessageSource(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 setNumberOfMessages(Object value)
Sets numberOfMessages
void setPollingPeriod(Long value)
Sets pollingPeriod
void setPreserveMessages(Object value)
Sets preserveMessages
void setQueueUrl(Object value)
Sets queueUrl
void setVisibilityTimeout(Object value)
Sets visibilityTimeout
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 Integer _numberOfMessagesType

protected Boolean _preserveMessagesType

protected String _queueUrlType

protected Integer _visibilityTimeoutType

protected Object numberOfMessages

static Long pollingPeriod

Polling Period for SourceStrategy.POLLING

protected Object preserveMessages

protected Object queueUrl

private Thread thread

Thread under which this message source will execute

protected Object visibilityTimeout

Public Constructors

public ReceiveMessagesMessageSource (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 setNumberOfMessages (Object value)

Sets numberOfMessages

Parameters
value Value to set

public void setPollingPeriod (Long value)

Sets pollingPeriod

Parameters
value Value to set

public void setPreserveMessages (Object value)

Sets preserveMessages

Parameters
value Value to set

public void setQueueUrl (Object value)

Sets queueUrl

Parameters
value Value to set

public void setVisibilityTimeout (Object value)

Sets visibilityTimeout

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