public class MessageProcessorAdminServiceClient extends Object
Modifier and Type | Field and Description |
---|---|
static int |
MESSAGE_PROCESSORS_PER_PAGE |
Constructor and Description |
---|
MessageProcessorAdminServiceClient(String cookie,
String backendServerUrl,
org.apache.axis2.context.ConfigurationContext configurationContext) |
Modifier and Type | Method and Description |
---|---|
void |
activate(String name) |
void |
addMessageProcessor(String xml)
This method will add Message processor to the synapse configuration
|
String |
browseMessage(String processorName)
Get the message from the associated queue
|
void |
deactivate(String name) |
void |
deleteAllMessages(String name) |
void |
deleteFirstMessage(String name) |
void |
deleteMessage(String name,
String messageId) |
void |
deleteMessageProcessor(String name) |
String |
getClassName(String name) |
String[] |
getDefinedEndpoints() |
String |
getEnvelope(String name,
String messageId) |
String[] |
getMessageIds(String name) |
MessageProcessorData |
getMessageProcessor(String name) |
org.wso2.carbon.message.processor.service.xsd.MessageProcessorMetaData[] |
getMessageProcessorMetaData() |
String[] |
getMessageProcessorNames() |
org.wso2.carbon.message.processor.service.xsd.MessageProcessorMetaData[] |
getPaginatedMessageProcessorData(int pageNumber) |
String[] |
getPaginatedMessageProcessorNames(int pageNumber) |
String[] |
getPaginatedMessages(String name,
int pageNumber) |
int |
getSize(String name) |
boolean |
isActive(String name) |
void |
modifyMessageProcessor(String xml) |
void |
popAndRedirectMessage(String processorName,
String storeName)
Pop the message from the associated queue and redirect to specified queue
|
void |
popMessage(String processorName)
Pop the message from the associated queue
|
void |
resendAllMessages(String name) |
void |
resendFirstMessage(String name,
String messageId) |
void |
resendMessage(String name,
String messageId) |
boolean |
validateAxis2ClientRepo(String axis2ClientRepo)
Checks whether given Axis2ClientRepo is valid one or not
|
public void addMessageProcessor(String xml) throws Exception
xml
- Exception
public void modifyMessageProcessor(String xml) throws Exception
Exception
public void deleteMessageProcessor(String name) throws Exception
Exception
public String[] getMessageProcessorNames() throws Exception
Exception
public String[] getPaginatedMessageProcessorNames(int pageNumber) throws Exception
Exception
public org.wso2.carbon.message.processor.service.xsd.MessageProcessorMetaData[] getPaginatedMessageProcessorData(int pageNumber) throws Exception
Exception
public MessageProcessorData getMessageProcessor(String name) throws Exception
Exception
public org.wso2.carbon.message.processor.service.xsd.MessageProcessorMetaData[] getMessageProcessorMetaData() throws Exception
Exception
public String getEnvelope(String name, String messageId) throws Exception
Exception
public void deleteMessage(String name, String messageId) throws Exception
Exception
public void resendMessage(String name, String messageId) throws Exception
Exception
public void resendFirstMessage(String name, String messageId) throws Exception
Exception
public String[] getPaginatedMessages(String name, int pageNumber) throws Exception
Exception
public boolean validateAxis2ClientRepo(String axis2ClientRepo) throws Exception
axis2ClientRepo
- input location of the Axis2 Client Repository given by the end user.true
if the given axis client repository valid, false
otherwise.Exception
- If any error is encountered during the validation process.public String browseMessage(String processorName) throws Exception
processorName
- The MessageProcessor namemessage
Returns message from the queue as a stringException
public void popMessage(String processorName) throws Exception
processorName
- The MessageProcessor nameException
public void popAndRedirectMessage(String processorName, String storeName) throws Exception
processorName
- MessageProcessor namestoreName
- Name of store to redirect the messageException
Copyright © 2019 WSO2. All rights reserved.