public class MessageStoreAdminService
extends org.wso2.carbon.mediation.initializer.AbstractServiceBusAdmin
Modifier and Type | Field and Description |
---|---|
static String |
EMPTY_STRING |
protected static org.apache.axiom.om.OMFactory |
fac |
static QName |
KEY_Q |
static int |
MSGS_PER_PAGE |
static QName |
NAME_Q |
protected static org.apache.axiom.om.OMNamespace |
nullNS |
static QName |
PARAMETER_Q |
static String |
REGISTRY_KEY_PREFIX |
static QName |
SEQUENCE_Q |
Constructor and Description |
---|
MessageStoreAdminService() |
Modifier and Type | Method and Description |
---|---|
void |
addMessageStore(String xml)
Get an XML configuration element for a message store from the FE and creates and add
the MessageStore to the synapse configuration.
|
void |
deleteAllMessages(String name) |
void |
deleteFirstMessages(String name) |
void |
deleteMessage(String name,
String messageId) |
void |
deleteMessageStore(String name)
Delete the MessageStore instance with given name in the synapse configuration
|
MessageInfo[] |
getAllMessages(String name)
Message information of All Messages in MessageStore
|
String |
getClassName(String name)
Get the implementation class name of the MessageStore
|
String |
getEnvelope(String name,
String messageId)
Get the Content of a given message
|
String |
getMessageStore(String name) |
MessageStoreMetaData[] |
getMessageStoreData()
Get all the Current Message store details defined in the configuration
|
String[] |
getMessageStoreNames()
Get all the Current Message store names defined in the configuration
|
MessageInfo[] |
getPaginatedMessages(String name,
int pageNumber)
Get Array of Messages that are needed for a given Page number
|
int |
getSize(String name)
Get the number of messages in the Message store with given name
|
void |
modifyMessageStore(String xml)
Modify and Existing Message store based on the given XML that is passed from the FE
This this case user may change the message store implementation/ change parameters
So we add and init new message store and then remove and destroy old.
|
getLock, getMediationPersistenceManager, getServerConfigurationInformation, getServerContextInformation, getSynapseConfiguration, getSynapseEnvironment, getSynapseEnvironment, lockSynapseConfiguration, unlockSynapseConfiguration
getAxisConfig, getConfigContext, getConfigSystemRegistry, getConfigUserRegistry, getGovernanceRegistry, getGovernanceSystemRegistry, getGovernanceUserRegistry, getHttpSession, getLocalRepo, getRegistry, getTenantDomain, getUsername, getUserRealm, setConfigurationContext, setPermissionUpdateTimestamp
public static final int MSGS_PER_PAGE
public static final QName NAME_Q
public static final QName SEQUENCE_Q
public static final QName KEY_Q
public static final QName PARAMETER_Q
public static final String REGISTRY_KEY_PREFIX
public static final String EMPTY_STRING
protected static final org.apache.axiom.om.OMFactory fac
protected static final org.apache.axiom.om.OMNamespace nullNS
public void addMessageStore(String xml) throws org.apache.axis2.AxisFault
xml
- string that contain the message store configuration.org.apache.axis2.AxisFault
- if some thing goes wrong when creating
a MessageStore with the given xml.public void modifyMessageStore(String xml) throws org.apache.axis2.AxisFault
xml
- XML configuration for the changed Message storeorg.apache.axis2.AxisFault
- if Some thing goes wrong when modifying the
Message storepublic String getMessageStore(String name) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void deleteMessageStore(String name) throws org.apache.axis2.AxisFault
name
- of the MessageStore to be deletedorg.apache.axis2.AxisFault
- if Message store does not existpublic String[] getMessageStoreNames() throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public MessageStoreMetaData[] getMessageStoreData() throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public int getSize(String name) throws org.apache.axis2.AxisFault
name
- of the MessageStoreorg.apache.axis2.AxisFault
- if Message store does not existspublic String getClassName(String name) throws org.apache.axis2.AxisFault
name
- of the MessageStoreorg.apache.axis2.AxisFault
public MessageInfo[] getAllMessages(String name) throws org.apache.axis2.AxisFault
name
- of the MessageStoreorg.apache.axis2.AxisFault
public MessageInfo[] getPaginatedMessages(String name, int pageNumber) throws org.apache.axis2.AxisFault
name
- of the message storepageNumber
- of to be displayedorg.apache.axis2.AxisFault
public String getEnvelope(String name, String messageId) throws org.apache.axis2.AxisFault
name
- of the message storemessageId
- Message id of the Messageorg.apache.axis2.AxisFault
public void deleteAllMessages(String name) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void deleteMessage(String name, String messageId) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void deleteFirstMessages(String name) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
Copyright © 2021 WSO2. All rights reserved.