public class

ReceiveMessageSource

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
         ↳ com.modus.mule.modules.as2.sources.ReceiveMessageSource

Class Overview

ReceiveMessageSource wraps receive(org.mule.api.callback.SourceCallback, java.lang.String, java.lang.Boolean, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Boolean, java.lang.Boolean, com.modus.mule.modules.as2.common.MicAlgorithmOptionEnum) method in AS2Connector 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 _keyStorePasswordType
protected String _keyStorePathType
protected MicAlgorithmOptionEnum _preferredMicAlgorithmType
protected String _receiptSubjectType
protected String _requireSenderAs2FromType
protected String _requireSenderAs2ToType
protected Boolean _requireSenderCompressType
protected Boolean _requireSenderEncryptsType
protected Boolean _requireSenderSignsType
protected Object keyStorePassword
protected Object keyStorePath
protected Object preferredMicAlgorithm
protected Object receiptSubject
protected Object requireSenderAs2From
protected Object requireSenderAs2To
protected Object requireSenderCompress
protected Object requireSenderEncrypts
protected Object requireSenderSigns
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
ReceiveMessageSource(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 setKeyStorePassword(Object value)
Sets keyStorePassword
void setKeyStorePath(Object value)
Sets keyStorePath
void setPreferredMicAlgorithm(Object value)
Sets preferredMicAlgorithm
void setReceiptSubject(Object value)
Sets receiptSubject
void setRequireSenderAs2From(Object value)
Sets requireSenderAs2From
void setRequireSenderAs2To(Object value)
Sets requireSenderAs2To
void setRequireSenderCompress(Object value)
Sets requireSenderCompress
void setRequireSenderEncrypts(Object value)
Sets requireSenderEncrypts
void setRequireSenderSigns(Object value)
Sets requireSenderSigns
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 _keyStorePasswordType

protected String _keyStorePathType

protected MicAlgorithmOptionEnum _preferredMicAlgorithmType

protected String _receiptSubjectType

protected String _requireSenderAs2FromType

protected String _requireSenderAs2ToType

protected Boolean _requireSenderCompressType

protected Boolean _requireSenderEncryptsType

protected Boolean _requireSenderSignsType

protected Object keyStorePassword

protected Object keyStorePath

protected Object preferredMicAlgorithm

protected Object receiptSubject

protected Object requireSenderAs2From

protected Object requireSenderAs2To

protected Object requireSenderCompress

protected Object requireSenderEncrypts

protected Object requireSenderSigns

private Thread thread

Thread under which this message source will execute

Public Constructors

public ReceiveMessageSource (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 setKeyStorePassword (Object value)

Sets keyStorePassword

Parameters
value Value to set

public void setKeyStorePath (Object value)

Sets keyStorePath

Parameters
value Value to set

public void setPreferredMicAlgorithm (Object value)

Sets preferredMicAlgorithm

Parameters
value Value to set

public void setReceiptSubject (Object value)

Sets receiptSubject

Parameters
value Value to set

public void setRequireSenderAs2From (Object value)

Sets requireSenderAs2From

Parameters
value Value to set

public void setRequireSenderAs2To (Object value)

Sets requireSenderAs2To

Parameters
value Value to set

public void setRequireSenderCompress (Object value)

Sets requireSenderCompress

Parameters
value Value to set

public void setRequireSenderEncrypts (Object value)

Sets requireSenderEncrypts

Parameters
value Value to set

public void setRequireSenderSigns (Object value)

Sets requireSenderSigns

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