Class MessageProcessorAdminServiceClient


  • public class MessageProcessorAdminServiceClient
    extends Object
    • Field Detail

      • MESSAGE_PROCESSORS_PER_PAGE

        public static int MESSAGE_PROCESSORS_PER_PAGE
    • Constructor Detail

      • MessageProcessorAdminServiceClient

        public MessageProcessorAdminServiceClient​(String cookie,
                                                  String backendServerUrl,
                                                  org.apache.axis2.context.ConfigurationContext configurationContext)
                                           throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
    • Method Detail

      • addMessageProcessor

        public void addMessageProcessor​(String xml)
                                 throws Exception
        This method will add Message processor to the synapse configuration
        Parameters:
        xml -
        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
      • getMessageProcessorMetaData

        public org.wso2.carbon.message.processor.service.xsd.MessageProcessorMetaData[] getMessageProcessorMetaData()
                                                                                                             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, else false
        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 name
        storeName - Name of store to redirect the message
        Returns:
        true if popAndRedirectMessage is successful, else false
        Throws:
        Exception