public class

HandleSubscriberRequestMessageProcessor

extends Object
implements SourceCallback FlowConstructAware MuleContextAware Disposable Initialisable Startable Stoppable InterceptingMessageProcessor
java.lang.Object
   ↳ org.mule.module.pubsubhubbub.processors.HandleSubscriberRequestMessageProcessor

Class Overview

HandleSubscriberRequestMessageProcessor invokes the handleSubscriberRequest(java.lang.String, java.lang.String, java.util.Map, java.lang.String, java.lang.String, org.mule.api.callback.SourceCallback) method in PuSHSubscriberModule. For each argument there is a field in this processor to match it. Before invoking the actual method the processor will evaluate and transform where possible to the expected argument type.

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
private String _contentTypeType
private String _httpMethodType
private String _onBehalfOfType
private String _payloadType
private Map<String, Object> _responseHeadersType
private Object contentType
private ExpressionManager expressionManager Mule Expression Manager
private FlowConstruct flowConstruct Flow construct
private Object httpMethod
private static Logger logger
private MessageProcessor messageProcessor Message processor that will get called for processing incoming events
private Object moduleObject Module object
private MuleContext muleContext Mule Context
private Object onBehalfOf
private TemplateParser.PatternInfo patternInfo Mule Pattern Info
private Object payload
private Object responseHeaders
private AtomicInteger retryCount Variable used to track how many retries we have attempted on this message processor
private int retryMax Maximum number of retries that can be attempted.
Public Constructors
HandleSubscriberRequestMessageProcessor()
Public Methods
void dispose()
void initialise()
Obtains the expression manager from the Mule context and initialises the connector.
Object process(Object message, Map<String, Object> properties)
Implements SourceCallback#process(org.mule.api.MuleEvent).
MuleEvent process(MuleEvent event)
Invokes the MessageProcessor.
Object process()
Implements process().
Object process(Object message)
Implements SourceCallback#process(org.mule.api.MuleEvent).
void setContentType(Object value)
Sets contentType
void setFlowConstruct(FlowConstruct flowConstruct)
Sets flow construct
void setHttpMethod(Object value)
Sets httpMethod
void setListener(MessageProcessor listener)
Sets the message processor that will "listen" the events generated by this message source
void setModuleObject(Object moduleObject)
Sets the instance of the object under which the processor will execute
void setMuleContext(MuleContext context)
Set the Mule context
void setOnBehalfOf(Object value)
Sets onBehalfOf
void setPayload(Object value)
Sets payload
void setResponseHeaders(Object value)
Sets responseHeaders
void setRetryMax(int value)
Sets retryMax
void start()
void stop()
[Expand]
Inherited Methods
From class java.lang.Object
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.MessageProcessor
From interface org.mule.api.source.MessageSource

Fields

private String _contentTypeType

private String _httpMethodType

private String _onBehalfOfType

private String _payloadType

private Map<String, Object> _responseHeadersType

private Object contentType

private ExpressionManager expressionManager

Mule Expression Manager

private FlowConstruct flowConstruct

Flow construct

private Object httpMethod

private static Logger logger

private MessageProcessor messageProcessor

Message processor that will get called for processing incoming events

private Object moduleObject

Module object

private MuleContext muleContext

Mule Context

private Object onBehalfOf

private TemplateParser.PatternInfo patternInfo

Mule Pattern Info

private Object payload

private Object responseHeaders

private AtomicInteger retryCount

Variable used to track how many retries we have attempted on this message processor

private int retryMax

Maximum number of retries that can be attempted.

Public Constructors

public HandleSubscriberRequestMessageProcessor ()

Public Methods

public void dispose ()

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 Object process (Object message, Map<String, Object> properties)

Implements SourceCallback#process(org.mule.api.MuleEvent). This message source will be passed on to the actual pojo's method as a callback mechanism.

Parameters
message
properties
Throws
Exception

public MuleEvent process (MuleEvent event)

Invokes the MessageProcessor.

Parameters
event MuleEvent to be processed
Throws
MuleException

public Object process ()

Implements process(). This message source will be passed on to the actual pojo's method as a callback mechanism.

Throws
Exception

public Object process (Object message)

Implements SourceCallback#process(org.mule.api.MuleEvent). This message source will be passed on to the actual pojo's method as a callback mechanism.

Parameters
message
Throws
Exception

public void setContentType (Object value)

Sets contentType

Parameters
value Value to set

public void setFlowConstruct (FlowConstruct flowConstruct)

Sets flow construct

Parameters
flowConstruct Flow construct to set

public void setHttpMethod (Object value)

Sets httpMethod

Parameters
value Value to set

public void setListener (MessageProcessor listener)

Sets the message processor that will "listen" the events generated by this message source

Parameters
listener Message processor

public void setModuleObject (Object moduleObject)

Sets the instance of the object under which the processor will execute

Parameters
moduleObject Instace of the module

public void setMuleContext (MuleContext context)

Set the Mule context

Parameters
context Mule context to set

public void setOnBehalfOf (Object value)

Sets onBehalfOf

Parameters
value Value to set

public void setPayload (Object value)

Sets payload

Parameters
value Value to set

public void setResponseHeaders (Object value)

Sets responseHeaders

Parameters
value Value to set

public void setRetryMax (int value)

Sets retryMax

Parameters
value Value to set

public void start ()

Throws
MuleException

public void stop ()

Throws
MuleException