org.wso2.esb.integration.common.clients.mediation

Class MessageProcessorClient

java.lang.Object

org.wso2.esb.integration.common.clients.mediation.MessageProcessorClient

public class MessageProcessorClient
extends Object

Constructor Summary

Constructors

Constructor and Description
MessageProcessorClient(String backEndUrl, String sessionCookie)
MessageProcessorClient(String backEndUrl, String userName, String password)

Method Summary

Modifier and Type	Method and Description
void	activateMessageProcessor(String processorName) Activate given message processor to resume processing of messages.
void	addMessageProcessor(DataHandler dh)
void	addMessageProcessor(org.apache.axiom.om.OMElement messageProcessor)
void	deactivateProcessor(String processorName) Pause processing of messages from given processor and deactivate.
void	deleteMessageProcessor(String messageProcessorName)
String	getMessageProcessor(String processorName) Get message processor by name.
String[]	getMessageProcessorNames()
boolean	isActive(String processorName) Check if message processor is active and handling messages.
void	modifyMessageProcessor(String xml) Update existing message processor configurations.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessageProcessorClient

public MessageProcessorClient(String backEndUrl,
                              String sessionCookie)
                       throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

MessageProcessorClient

public MessageProcessorClient(String backEndUrl,
                              String userName,
                              String password)
                       throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

Method Detail

addMessageProcessor

public void addMessageProcessor(DataHandler dh)
                         throws IOException,
                                XMLStreamException

Throws:

IOException

XMLStreamException

addMessageProcessor

public void addMessageProcessor(org.apache.axiom.om.OMElement messageProcessor)
                         throws RemoteException

Throws:

RemoteException

deleteMessageProcessor

public void deleteMessageProcessor(String messageProcessorName)
                            throws RemoteException

Throws:

RemoteException

getMessageProcessorNames

public String[] getMessageProcessorNames()
                                  throws RemoteException

Throws:

RemoteException

modifyMessageProcessor

public void modifyMessageProcessor(String xml)
                            throws RemoteException

Update existing message processor configurations.

Parameters:

xml - new configuration

Throws:

RemoteException

getMessageProcessor

public String getMessageProcessor(String processorName)
                           throws RemoteException

Get message processor by name.

Parameters:

processorName - processor name

Returns:

XML configuration of message processor

Throws:

RemoteException

activateMessageProcessor

public void activateMessageProcessor(String processorName)
                              throws RemoteException

Activate given message processor to resume processing of messages.

Parameters:

processorName - name of Processor

Throws:

RemoteException

deactivateProcessor

public void deactivateProcessor(String processorName)
                         throws RemoteException

Pause processing of messages from given processor and deactivate.

Parameters:

processorName - name of Processor

Throws:

RemoteException

isActive

public boolean isActive(String processorName)
                 throws RemoteException

Check if message processor is active and handling messages.

Parameters:

processorName - name of Processor

Returns:

true if processor is active

Throws:

RemoteException