Class MessageProcessorAdminServiceClient
- java.lang.Object
-
- org.wso2.carbon.message.processor.ui.MessageProcessorAdminServiceClient
-
public class MessageProcessorAdminServiceClient extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static int
MESSAGE_PROCESSORS_PER_PAGE
-
Constructor Summary
Constructors Constructor Description MessageProcessorAdminServiceClient(String cookie, String backendServerUrl, org.apache.axis2.context.ConfigurationContext configurationContext)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
activate(String name)
void
addMessageProcessor(String xml)
This method will add Message processor to the synapse configurationString
browseMessage(String processorName)
Get the message from the associated queuevoid
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)
boolean
isTaskLocationKnown(String name)
void
modifyMessageProcessor(String xml)
boolean
popAndRedirectMessage(String processorName, String storeName)
Pop the message from the associated queue and redirect to specified queueboolean
popMessage(String processorName)
Pop the message from the associated queuevoid
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
-
-
-
Method Detail
-
addMessageProcessor
public void addMessageProcessor(String xml) throws Exception
This method will add Message processor to the synapse configuration- Parameters:
xml
-- Throws:
Exception
-
modifyMessageProcessor
public void modifyMessageProcessor(String xml) throws Exception
- Throws:
Exception
-
deleteMessageProcessor
public void deleteMessageProcessor(String name) throws Exception
- Throws:
Exception
-
getMessageProcessorNames
public String[] getMessageProcessorNames() throws Exception
- Throws:
Exception
-
getPaginatedMessageProcessorNames
public String[] getPaginatedMessageProcessorNames(int pageNumber) throws Exception
- Throws:
Exception
-
getPaginatedMessageProcessorData
public org.wso2.carbon.message.processor.service.xsd.MessageProcessorMetaData[] getPaginatedMessageProcessorData(int pageNumber) throws Exception
- Throws:
Exception
-
getMessageProcessor
public MessageProcessorData getMessageProcessor(String name) throws Exception
- Throws:
Exception
-
getMessageProcessorMetaData
public org.wso2.carbon.message.processor.service.xsd.MessageProcessorMetaData[] getMessageProcessorMetaData() throws Exception
- Throws:
Exception
-
getEnvelope
public String getEnvelope(String name, String messageId) throws Exception
- Throws:
Exception
-
deleteMessage
public void deleteMessage(String name, String messageId) throws Exception
- Throws:
Exception
-
resendMessage
public void resendMessage(String name, String messageId) throws Exception
- Throws:
Exception
-
resendFirstMessage
public void resendFirstMessage(String name, String messageId) throws Exception
- Throws:
Exception
-
getPaginatedMessages
public String[] getPaginatedMessages(String name, int pageNumber) throws Exception
- Throws:
Exception
-
isTaskLocationKnown
public boolean isTaskLocationKnown(String name) throws Exception
- Throws:
Exception
-
validateAxis2ClientRepo
public boolean validateAxis2ClientRepo(String axis2ClientRepo) throws Exception
Checks whether given Axis2ClientRepo is valid one or not- Parameters:
axis2ClientRepo
- input location of the Axis2 Client Repository given by the end user.- Returns:
true
if the given axis client repository valid,false
otherwise.- Throws:
Exception
- If any error is encountered during the validation process.
-
browseMessage
public String browseMessage(String processorName) throws Exception
Get the message from the associated queue- Parameters:
processorName
- The MessageProcessor name- Returns:
message
Returns message from the queue as a string- Throws:
Exception
-
popMessage
public boolean popMessage(String processorName) throws Exception
Pop the message from the associated queue- Parameters:
processorName
- The MessageProcessor name- Returns:
true
if popMessage is successful, elsefalse
- Throws:
Exception
-
popAndRedirectMessage
public boolean popAndRedirectMessage(String processorName, String storeName) throws Exception
Pop the message from the associated queue and redirect to specified queue- Parameters:
processorName
- MessageProcessor namestoreName
- Name of store to redirect the message- Returns:
true
if popAndRedirectMessage is successful, elsefalse
- Throws:
Exception
-
-