public abstract class AbstractListeningMessageProcessor extends DevkitBasedMessageProcessor implements SourceCallback, MessageProcessorContainer
flowConstruct, moduleObject, muleContext
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
AbstractListeningMessageProcessor(String operationName) |
Modifier and Type | Method and Description |
---|---|
void |
addMessageProcessorPathElements(MessageProcessorPathElement pathElement)
Add the child nodes to the path element tree.
|
protected MuleEvent |
doProcess(MuleEvent event)
Not valid for this class or its extensions
|
MessageProcessor |
getMessageProcessor()
Retrieves messageProcessor
|
Object |
process()
Implements
SourceCallback.process() . |
Object |
process(Object message)
Implements
SourceCallback.process(Object) . |
Object |
process(Object message,
Map<String,Object> properties)
Implements
SourceCallback.process(Object) . |
MuleEvent |
processEvent(MuleEvent event)
|
void |
setListener(MessageProcessor listener)
Sets the message processor that will "listen" the events generated by this
message source
|
dispose, findOrCreate, getAccessTokenId, getFlowConstruct, getMuleContext, initialise, overwritePayload, process, setAccessTokenId, setFlowConstruct, setModuleObject, setMuleContext, start, stop
computeClassHierarchy, evaluate, evaluateAndTransform, evaluateAndTransform, getAccessTokenId, isAssignableFrom, isList, isListClass, isMap, isMapClass, transform, transform, transform
public AbstractListeningMessageProcessor(String operationName)
public MessageProcessor getMessageProcessor()
public void setListener(MessageProcessor listener)
listener
- Message processorpublic Object process(Object message) throws Exception
SourceCallback.process(Object)
. This
message source will be passed on to the actual pojo's method as a callback
mechanism.process
in interface SourceCallback
message
- The payload of the messageException
public Object process(Object message, Map<String,Object> properties) throws Exception
SourceCallback.process(Object)
. This
message source will be passed on to the actual pojo's method as a callback
mechanism.process
in interface SourceCallback
message
- The payload of the messageproperties
- Properties to be attached with inbound scopeException
public Object process() throws Exception
SourceCallback.process()
. This message source will be
passed on to the actual pojo's method as a callback mechanism.process
in interface SourceCallback
Exception
public MuleEvent processEvent(MuleEvent event) throws MuleException
SourceCallback.processEvent(org.mule.api.MuleEvent)
. This
message source will be passed on to the actual pojo's method as a callback
mechanism.processEvent
in interface SourceCallback
MuleException
protected MuleEvent doProcess(MuleEvent event) throws Exception
doProcess
in class DevkitBasedMessageProcessor
event
- the mule eventUnsupportedOperationException
Exception
public void addMessageProcessorPathElements(MessageProcessorPathElement pathElement)
MessageProcessorContainer
addMessageProcessorPathElements
in interface MessageProcessorContainer
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.