public abstract class AbstractMessageProcessor extends Object implements MessageProcessor
AbstractMessageProcessor
is handles Message processing of the messages
in Message Store. Abstract Message Store is assumes that Message processors can be implemented
using the quartz scheduler jobs. If in case we user wants a different implementation They can
directly use MessageProcessor
interface for that implementationsModifier and Type | Field and Description |
---|---|
protected String |
artifactContainerName
Name of the artifact container from which the message processor deployed
|
protected SynapseConfiguration |
configuration |
protected String |
description |
protected String |
fileName |
protected boolean |
isEdited
Whether the message processor edited via the management console
|
protected List<MessageConsumer> |
messageConsumers |
protected String |
messageStore
Message Store associated with Message processor
|
protected String |
name |
protected Map<String,Object> |
parameters
message store parameters
|
protected String |
targetEndpoint
This attribute is only need for forwarding message processor.
|
Constructor and Description |
---|
AbstractMessageProcessor() |
Modifier and Type | Method and Description |
---|---|
String |
getArtifactContainerName()
Get the name of the artifact container from which the message processor deployed
|
String |
getDescription()
Retrieves the description of the artifact
|
String |
getFileName()
This method is used to retrieve the configuration file name of the message processor.
|
List<MessageConsumer> |
getMessageConsumer()
This method retrieves the message consumer of message processor.
|
String |
getMessageStoreName()
This method returns the associated message store name of the message processor.
|
String |
getName()
Get the name of an abstraction
|
Map<String,Object> |
getParameters()
This method is used to retrieve the configuration parameters of message processor.
|
String |
getTargetEndpoint()
This method is used to retrieve the associated target endpoint name of the message processor.
|
void |
init(SynapseEnvironment se)
This method should implement the initialization of the
implemented parts of the configuration.
|
boolean |
isEdited()
Whether the message processor edited through the management console
|
void |
setArtifactContainerName(String artifactContainerName)
Set the name of the artifact container from which the message processor deployed
|
void |
setDescription(String description)
Set the description of the artifact
|
void |
setFileName(String filename)
This method is used to set the actual configuration file.
|
void |
setIsEdited(boolean isEdited)
Set whether the message processor edited through the management console
|
boolean |
setMessageConsumer(MessageConsumer consumer)
This method is used to set the message consumer of message processor.
|
void |
setMessageStoreName(String messageStore)
This method is used to set the associated message store of the message processor.
|
void |
setName(String name)
Set the name of an abstraction
|
void |
setParameters(Map<String,Object> parameters)
This method is used to set configuration parameters of the message processor.
|
void |
setTargetEndpoint(String targetEndpoint)
This method set the target endpoint associated with the message processor.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
activate, cleanupLocalResources, deactivate, isDeactivated, isPaused, pauseService, resumeService, start, stop
destroy
protected String messageStore
protected String description
protected String name
protected String fileName
protected SynapseConfiguration configuration
protected List<MessageConsumer> messageConsumers
protected String artifactContainerName
protected boolean isEdited
protected String targetEndpoint
public void init(SynapseEnvironment se)
ManagedLifecycle
init
in interface ManagedLifecycle
se
- SynapseEnvironment to be used for initializationpublic void setMessageStoreName(String messageStore)
MessageProcessor
setMessageStoreName
in interface MessageProcessor
messageStore
- Name of this message store.public String getMessageStoreName()
MessageProcessor
getMessageStoreName
in interface MessageProcessor
public void setParameters(Map<String,Object> parameters)
MessageProcessor
setParameters
in interface MessageProcessor
parameters
- Message processor parameters.public Map<String,Object> getParameters()
MessageProcessor
getParameters
in interface MessageProcessor
public String getName()
Nameable
public void setName(String name)
Nameable
public void setDescription(String description)
SynapseArtifact
setDescription
in interface SynapseArtifact
description
- tobe set to the artifactpublic String getDescription()
SynapseArtifact
getDescription
in interface SynapseArtifact
public void setFileName(String filename)
MessageProcessor
setFileName
in interface MessageProcessor
filename
- is the name of the filepublic String getFileName()
MessageProcessor
getFileName
in interface MessageProcessor
public List<MessageConsumer> getMessageConsumer()
MessageProcessor
getMessageConsumer
in interface MessageProcessor
public boolean setMessageConsumer(MessageConsumer consumer)
MessageProcessor
setMessageConsumer
in interface MessageProcessor
consumer
- is the name of the associated message consumerpublic void setTargetEndpoint(String targetEndpoint)
MessageProcessor
setTargetEndpoint
in interface MessageProcessor
targetEndpoint
- is the name of the associated endpointpublic String getTargetEndpoint()
MessageProcessor
getTargetEndpoint
in interface MessageProcessor
public boolean isEdited()
isEdited
in interface MessageProcessor
public void setIsEdited(boolean isEdited)
setIsEdited
in interface MessageProcessor
isEdited
- public String getArtifactContainerName()
getArtifactContainerName
in interface MessageProcessor
public void setArtifactContainerName(String artifactContainerName)
setArtifactContainerName
in interface MessageProcessor
artifactContainerName
- Copyright © 2005–2017 Apache Software Foundation. All rights reserved.