public class MessageProcessorAdminService
extends org.wso2.carbon.mediation.initializer.AbstractServiceBusAdmin
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_AXIS2_XML |
static int |
MSGS_PER_PAGE |
Constructor and Description |
---|
MessageProcessorAdminService() |
Modifier and Type | Method and Description |
---|---|
void |
activate(String processorName) |
void |
addMessageProcessor(String xml)
Get an XML configuration element for a message processor from the FE and creates and add
the MessageStore to the synapse configuration.
|
String |
browseMessage(String processorName)
Gets the message from the associated queue.
|
void |
deactivate(String processorName) |
void |
deleteAllMessages(String processorName)
Delete all messages from the Message Store associated with the Processor
|
void |
deleteFirstMessages(String processorName)
Delete first messages from the Message Store associated with the Processor
|
void |
deleteMessage(String processorName,
String messageId)
Delete a Message with given Message id for the associated store
|
void |
deleteMessageProcessor(String name)
Delete the MessageProcessor instance with given name in the synapse configuration
|
String |
getClassName(String name)
Get the implementation class name of the MessageProcessor
|
String[] |
getDefinedEndpoints() |
String |
getEnvelope(String processorName,
String messageId)
Get the SOAP Envelope of the Requested message from the associated Store
|
String[] |
getMessageIds(String processorName)
Get All the Messages Stored in the Message Store associated with the Processor
|
String |
getMessageProcessor(String name)
Get the Synapse configuration for a Message processor
|
MessageProcessorMetaData[] |
getMessageProcessorDataList()
Get all the Current Message processor data defined in the configuration
|
String[] |
getMessageProcessorNames()
Get all the Current Message processor names defined in the configuration
|
int |
getSize(String processorName)
Get the Number of Messages in the message store associated with the processor
|
boolean |
isActive(String processorName)
Get the Active Status of the message processor
|
boolean |
isTaskLocationKnown(String processorName) |
void |
modifyMessageProcessor(String xml)
Modify and Existing Message processor based on the given XML that is passed from the FE
|
boolean |
popAndRedirectMessage(String processorName,
String storeName)
Pops the message and redirects it to a specified queue.
|
boolean |
popMessage(String processorName)
Pops the message from the associated queue.
|
void |
resend(String processorName,
String messageId)
Resend a Give Message
|
void |
resendAll(String processorName)
messageID
Resend All messages
|
void |
resendFirstMessage(String processorName,
String messageId)
Resend first Message
|
boolean |
validateAxis2ClientRepo(String input)
Checks whether given Axis2ClientRepo is valid one or not
|
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 String DEFAULT_AXIS2_XML
public void addMessageProcessor(String xml) throws org.apache.axis2.AxisFault
xml
- string that contain the message processor configuration.org.apache.axis2.AxisFault
- if some thing goes wrong when creating
a MessageProcessor with the given xml.public void modifyMessageProcessor(String xml) throws org.apache.axis2.AxisFault
xml
- XML configuration for the changed Message processororg.apache.axis2.AxisFault
- if Some thing goes wrong when modifying the
Message processorpublic String getMessageProcessor(String name) throws org.apache.axis2.AxisFault
name
- name of the message processororg.apache.axis2.AxisFault
public void deleteMessageProcessor(String name) throws org.apache.axis2.AxisFault
name
- of the MessageProcessor to be deletedorg.apache.axis2.AxisFault
- if Message processor does not existpublic String[] getMessageProcessorNames() throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public String[] getMessageIds(String processorName) throws org.apache.axis2.AxisFault
processorName
- ScheduledMessageForwarding Processor Nameorg.apache.axis2.AxisFault
public MessageProcessorMetaData[] getMessageProcessorDataList() throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public String getEnvelope(String processorName, String messageId) throws org.apache.axis2.AxisFault
processorName
- Message Processor NamemessageId
- Message id of the Messageorg.apache.axis2.AxisFault
public void deleteMessage(String processorName, String messageId) throws org.apache.axis2.AxisFault
processorName
- message processor namemessageId
- message id of the message to be deletedorg.apache.axis2.AxisFault
public void deleteFirstMessages(String processorName) throws org.apache.axis2.AxisFault
processorName
- Message Processor Nameorg.apache.axis2.AxisFault
public void deleteAllMessages(String processorName) throws org.apache.axis2.AxisFault
processorName
- Message Processor Nameorg.apache.axis2.AxisFault
public void resend(String processorName, String messageId) throws org.apache.axis2.AxisFault
processorName
- messageId
- org.apache.axis2.AxisFault
public void resendFirstMessage(String processorName, String messageId) throws org.apache.axis2.AxisFault
processorName
- messageId
- org.apache.axis2.AxisFault
public void resendAll(String processorName) throws org.apache.axis2.AxisFault
processorName
- org.apache.axis2.AxisFault
public int getSize(String processorName) throws org.apache.axis2.AxisFault
processorName
- org.apache.axis2.AxisFault
public boolean isActive(String processorName) throws org.apache.axis2.AxisFault
processorName
- org.apache.axis2.AxisFault
public boolean isTaskLocationKnown(String processorName) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void activate(String processorName) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void deactivate(String processorName) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public String getClassName(String name) throws org.apache.axis2.AxisFault
name
- of the MessageProcessororg.apache.axis2.AxisFault
public String[] getDefinedEndpoints() throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public boolean validateAxis2ClientRepo(String input) throws org.apache.axis2.AxisFault
input
- location of the Axis2 Client Repositorytrue
if the given axis client repository valid, false
otherwise.org.apache.axis2.AxisFault
- If an ERROR is encountered or given repository location is invalid.public String browseMessage(String processorName) throws org.apache.axis2.AxisFault
processorName
- message processor name.message
returns message received from the queue as a string.org.apache.axis2.AxisFault
public boolean popMessage(String processorName) throws org.apache.axis2.AxisFault
processorName
- message processor name.true
if ++ is successful, else false
org.apache.axis2.AxisFault
public boolean popAndRedirectMessage(String processorName, String storeName) throws org.apache.axis2.AxisFault
processorName
- message processor name.storeName
- name of the store to redirect the message.true
if ++ is successful, else false
org.apache.axis2.AxisFault
Copyright © 2022 WSO2. All rights reserved.