public interface MessageStore extends ManagedLifecycle, Nameable, SynapseArtifact
Modifier and Type | Method and Description |
---|---|
void |
addParameter(java.lang.String name,
java.lang.String key)
Adds message store specific parameters
|
void |
addParameterKey(java.lang.String name,
java.lang.String key)
Adds message store parameter registry keys
|
void |
clear()
Delete all the Messages in the Message Store
|
MessageContext |
get(int index)
Return the Message in given index position
(this may depend on the implementation)
|
MessageContext |
get(java.lang.String messageId)
Get the Message with the given ID from the Message store without removing it
|
java.util.List<MessageContext> |
getAll()
Get the All messages in the Message store without removing them from the queue
|
java.lang.String |
getArtifactContainerName()
Get the name of the artifact container from which the message store deployed
|
MessageConsumer |
getConsumer()
Returns a Message Consumer for this message store.
|
java.lang.String |
getFileName()
get the file name that the message store is configured
|
java.lang.String |
getParameterKey(java.lang.String name)
Gets parameter registry key from the parameter name
|
java.util.Map<java.lang.String,java.lang.String> |
getParameterKeyMap()
Gets registry key mappings for the parameters
|
java.util.Map<java.lang.String,java.lang.Object> |
getParameters()
get the implementation specific parameters of the Message store
|
MessageProducer |
getProducer()
Returns a Message Producer for this message store.
|
int |
getType()
Returns the type of this message store.
|
boolean |
isEdited()
Whether the message store edited through the management console
|
MessageContext |
remove()
Retrieves and removes the first Message in this store.
|
MessageContext |
remove(java.lang.String messageID)
Delete and return the MessageContext with given Message id
|
void |
setArtifactContainerName(java.lang.String artifactContainerName)
Set the name of the artifact container from which the message store deployed
|
void |
setFileName(java.lang.String filename)
Set the name of the file that the Message store is configured
|
void |
setIsEdited(boolean isEdited)
Set whether the message store edited through the management console
|
void |
setParameters(java.util.Map<java.lang.String,java.lang.Object> parameters)
set the implementation specific parameters
|
int |
size()
Returns the number of Messages in this store.
|
destroy, init
getDescription, setDescription
MessageProducer getProducer() throws SynapseException
SynapseException
MessageConsumer getConsumer() throws SynapseException
SynapseException
void setParameters(java.util.Map<java.lang.String,java.lang.Object> parameters)
parameters
- A map of parameters or nulljava.util.Map<java.lang.String,java.lang.Object> getParameters()
void addParameter(java.lang.String name, java.lang.String key)
name
- parameter namekey
- parameter key valuevoid addParameterKey(java.lang.String name, java.lang.String key)
name
- parameter namekey
- parameter registry key valuejava.lang.String getParameterKey(java.lang.String name)
name
- parameter namejava.util.Map<java.lang.String,java.lang.String> getParameterKeyMap()
void setFileName(java.lang.String filename)
filename
- Name of the file where this artifact is definedjava.lang.String getFileName()
int getType()
Constants.JMS_MS
, Constants.INMEMORY_MS
,
or Constants.JDBC_MS
MessageContext remove() throws java.util.NoSuchElementException
java.util.NoSuchElementException
- if store is emptyvoid clear()
MessageContext remove(java.lang.String messageID)
messageID
- message id of the Messageint size()
MessageContext get(int index)
index
- position of the messagejava.util.List<MessageContext> getAll()
MessageContext get(java.lang.String messageId)
messageId
- A message ID stringboolean isEdited()
void setIsEdited(boolean isEdited)
isEdited
- true if Message Store config is locally editedjava.lang.String getArtifactContainerName()
void setArtifactContainerName(java.lang.String artifactContainerName)
artifactContainerName
- name of artifact containerCopyright © 2005-2022 Apache Software Foundation. All Rights Reserved.