org.wso2.das4is.integration.common.clients

Class EventProcessorAdminServiceClient

java.lang.Object

org.wso2.das4is.integration.common.clients.EventProcessorAdminServiceClient

public class EventProcessorAdminServiceClient
extends Object

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.axis2.client.ServiceClient	_getServiceClient()
void	addExecutionPlan(String executionPlan)
void	editActiveExecutionPlan(String executionPlan, String executionPlanName)
String	getActiveExecutionPlan(String executionPlanName)
org.wso2.carbon.event.processor.stub.types.ExecutionPlanConfigurationDto	getActiveExecutionPlanConfiguration(String executionPlanName)
int	getActiveExecutionPlanConfigurationCount()
org.wso2.carbon.event.processor.stub.types.ExecutionPlanConfigurationDto[]	getAllExportedStreamSpecificActiveExecutionPlanConfiguration(String streamId)
int	getExecutionPlanConfigurationCount()
int	getInactiveExecutionPlanConfigurationCount()
org.wso2.carbon.event.processor.stub.types.StreamDefinitionDto[]	getSiddhiStreams(String executionPlan)
void	removeActiveExecutionPlan(String planName)
void	removeInactiveExecutionPlan(String filePath)
void	setStatisticsEnabled(String executionPlanName, boolean isEnabled)
void	setTracingEnabled(String executionPlanName, boolean isEnabled)
String	validateExecutionPlan(String executionPlan)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventProcessorAdminServiceClient

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

Throws:

org.apache.axis2.AxisFault

EventProcessorAdminServiceClient

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

Throws:

org.apache.axis2.AxisFault

Method Detail

_getServiceClient

public org.apache.axis2.client.ServiceClient _getServiceClient()

getActiveExecutionPlanConfigurationCount

public int getActiveExecutionPlanConfigurationCount()
                                             throws RemoteException

Throws:

RemoteException

getInactiveExecutionPlanConfigurationCount

public int getInactiveExecutionPlanConfigurationCount()
                                               throws RemoteException

Throws:

RemoteException

getExecutionPlanConfigurationCount

public int getExecutionPlanConfigurationCount()
                                       throws RemoteException

Throws:

RemoteException

getActiveExecutionPlanConfiguration

public org.wso2.carbon.event.processor.stub.types.ExecutionPlanConfigurationDto getActiveExecutionPlanConfiguration(String executionPlanName)
                                                                                                             throws RemoteException

Throws:

RemoteException

getActiveExecutionPlan

public String getActiveExecutionPlan(String executionPlanName)
                              throws RemoteException

Throws:

RemoteException

addExecutionPlan

public void addExecutionPlan(String executionPlan)
                      throws RemoteException

Throws:

RemoteException

removeActiveExecutionPlan

public void removeActiveExecutionPlan(String planName)
                               throws RemoteException

Throws:

RemoteException

removeInactiveExecutionPlan

public void removeInactiveExecutionPlan(String filePath)
                                 throws RemoteException

Throws:

RemoteException

editActiveExecutionPlan

public void editActiveExecutionPlan(String executionPlan,
                           String executionPlanName)
                             throws RemoteException

Throws:

RemoteException

validateExecutionPlan

public String validateExecutionPlan(String executionPlan)
                             throws RemoteException

Throws:

RemoteException

setStatisticsEnabled

public void setStatisticsEnabled(String executionPlanName,
                        boolean isEnabled)
                          throws RemoteException

Throws:

RemoteException

setTracingEnabled

public void setTracingEnabled(String executionPlanName,
                     boolean isEnabled)
                       throws RemoteException

Throws:

RemoteException

getSiddhiStreams

public org.wso2.carbon.event.processor.stub.types.StreamDefinitionDto[] getSiddhiStreams(String executionPlan)
                                                                                  throws RemoteException

Throws:

RemoteException

getAllExportedStreamSpecificActiveExecutionPlanConfiguration

public org.wso2.carbon.event.processor.stub.types.ExecutionPlanConfigurationDto[] getAllExportedStreamSpecificActiveExecutionPlanConfiguration(String streamId)
                                                                                                                                        throws RemoteException

Throws:

RemoteException