public interface MessageProcessor extends ManagedLifecycle, Nameable, SynapseArtifact
MessageProcessor interface
Message processors will process the Message using a Message Store.
Message processing logic and process will depend on the
concrete implementation of the MessageStore| Modifier and Type | Method and Description |
|---|---|
String |
getFileName()
get the file name that the message processor is configured
|
String |
getMessageStoreName()
Get message store name associated with the Message processor
|
Map<String,Object> |
getParameters()
Get the Message processor Parameters
|
boolean |
isStarted()
Returns weather a Message processor is started or not
|
void |
setFileName(String filename)
Set the name of the file that the Message Processor is configured
|
void |
setMessageStoreName(String messageStore)
Set the Message Store name that backs the Message processor
|
void |
setParameters(Map<String,Object> parameters)
Set the Message processor parameters that will be used by the specific implementation
|
void |
start()
Start Message Processor
|
void |
stop()
Stop MessageProcessor
|
destroy, initgetDescription, setDescriptionvoid start()
void stop()
void setMessageStoreName(String messageStore)
messageStore - name the underlying MessageStore instanceString getMessageStoreName()
void setParameters(Map<String,Object> parameters)
parameters - boolean isStarted()
void setFileName(String filename)
filename - Name of the file where this artifact is definedString getFileName()
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.