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 MessageStoreModifier 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, init
getDescription, setDescription
void 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.