public abstract class AbstractMessageStore extends java.lang.Object implements MessageStore
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
description
Message Store description
|
protected java.lang.String |
fileName
Name of the file where this message store is defined
|
protected java.util.concurrent.locks.Lock |
lock |
protected MessageStoreView |
messageStoreMBean
Message store JMX view
|
protected java.util.List<MessageStoreObserver> |
messageStoreObservers
List that holds the MessageStore observers registered with the Message Store
|
protected java.lang.String |
name
message store name
|
protected java.util.Map<java.lang.String,java.lang.String> |
parameterKeyMap
Message store parameters with registry keys
|
protected java.util.Map<java.lang.String,java.lang.Object> |
parameters
Message store parameters
|
protected java.lang.String |
sequence
name of the sequence to be executed before storing the message
|
protected SynapseConfiguration |
synapseConfiguration
synapse configuration reference
|
protected SynapseEnvironment |
synapseEnvironment
synapse environment reference
|
Constructor and Description |
---|
AbstractMessageStore() |
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 |
dequeued() |
void |
destroy()
This method should implement the destroying of the
implemented parts of the configuration.
|
long |
difference() |
void |
enqueued() |
java.lang.String |
getArtifactContainerName()
Get the name of the artifact container from which the message store deployed
|
java.lang.String |
getDescription()
Retrieves the description of the artifact
|
java.lang.String |
getFileName()
get the file name that the message store is configured
|
java.util.concurrent.locks.Lock |
getLock() |
java.lang.String |
getName()
Get the name of an abstraction
|
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
|
int |
getType()
Returns the type of this message store.
|
void |
init(SynapseEnvironment se)
This method should implement the initialization of the
implemented parts of the configuration.
|
boolean |
isEdited()
Whether the message store edited through the management console
|
int |
nextConsumerId() |
int |
nextProducerId() |
protected void |
notifyMessageAddition(java.lang.String messageId)
Notify Message Addition to the observers
|
protected void |
notifyMessageRemoval(java.lang.String messageId)
Notify Message removal to the observers
|
void |
registerObserver(MessageStoreObserver observer) |
void |
setArtifactContainerName(java.lang.String artifactContainerName)
Set the name of the artifact container from which the message store deployed
|
void |
setDescription(java.lang.String description)
Set the description of the artifact
|
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 |
setName(java.lang.String name)
Set the name of an abstraction
|
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.
|
void |
unregisterObserver(MessageStoreObserver observer) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clear, get, get, getAll, getConsumer, getProducer, remove, remove
protected java.lang.String name
protected java.lang.String sequence
protected MessageStoreView messageStoreMBean
protected SynapseConfiguration synapseConfiguration
protected SynapseEnvironment synapseEnvironment
protected java.util.Map<java.lang.String,java.lang.Object> parameters
protected java.util.Map<java.lang.String,java.lang.String> parameterKeyMap
protected java.lang.String description
protected java.lang.String fileName
protected java.util.List<MessageStoreObserver> messageStoreObservers
protected java.util.concurrent.locks.Lock lock
public void init(SynapseEnvironment se)
ManagedLifecycle
init
in interface ManagedLifecycle
se
- SynapseEnvironment to be used for initializationpublic java.lang.String getName()
Nameable
public void setName(java.lang.String name)
Nameable
public void registerObserver(MessageStoreObserver observer)
public void unregisterObserver(MessageStoreObserver observer)
protected void notifyMessageAddition(java.lang.String messageId)
messageId
- of the Message added.protected void notifyMessageRemoval(java.lang.String messageId)
messageId
- of the Message addedpublic int size()
MessageStore
size
in interface MessageStore
public java.util.Map<java.lang.String,java.lang.Object> getParameters()
MessageStore
getParameters
in interface MessageStore
public void setParameters(java.util.Map<java.lang.String,java.lang.Object> parameters)
MessageStore
setParameters
in interface MessageStore
parameters
- A map of parameters or nullpublic void addParameter(java.lang.String name, java.lang.String key)
MessageStore
addParameter
in interface MessageStore
name
- parameter namekey
- parameter key valuepublic void addParameterKey(java.lang.String name, java.lang.String key)
MessageStore
addParameterKey
in interface MessageStore
name
- parameter namekey
- parameter registry key valuepublic java.lang.String getParameterKey(java.lang.String name)
MessageStore
getParameterKey
in interface MessageStore
name
- parameter namepublic java.util.Map<java.lang.String,java.lang.String> getParameterKeyMap()
MessageStore
getParameterKeyMap
in interface MessageStore
public void destroy()
ManagedLifecycle
destroy
in interface ManagedLifecycle
public void setDescription(java.lang.String description)
SynapseArtifact
setDescription
in interface SynapseArtifact
description
- tobe set to the artifactpublic java.lang.String getDescription()
SynapseArtifact
getDescription
in interface SynapseArtifact
public void setFileName(java.lang.String filename)
MessageStore
setFileName
in interface MessageStore
filename
- Name of the file where this artifact is definedpublic java.lang.String getFileName()
MessageStore
getFileName
in interface MessageStore
public int getType()
MessageStore
Constants.JMS_MS
, Constants.INMEMORY_MS
,
or Constants.JDBC_MS
getType
in interface MessageStore
public java.util.concurrent.locks.Lock getLock()
public int nextProducerId()
public int nextConsumerId()
public void enqueued()
public void dequeued()
public long difference()
public boolean isEdited()
isEdited
in interface MessageStore
public void setIsEdited(boolean isEdited)
setIsEdited
in interface MessageStore
isEdited
- public java.lang.String getArtifactContainerName()
getArtifactContainerName
in interface MessageStore
public void setArtifactContainerName(java.lang.String artifactContainerName)
setArtifactContainerName
in interface MessageStore
artifactContainerName
- Copyright © 2005-2021 Apache Software Foundation. All Rights Reserved.