org.wso2.das4is.integration.common.clients

Class EventSimulatorAdminServiceClient

java.lang.Object

org.wso2.das4is.integration.common.clients.EventSimulatorAdminServiceClient

public class EventSimulatorAdminServiceClient
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
org.apache.axis2.client.ServiceClient	_getServiceClient()
boolean	deleteDBConfigFile(String fileName)
boolean	deleteFile(String fileName)
org.wso2.carbon.event.simulator.stub.types.DataSourceTableAndStreamInfoDto[]	getAllDataSourceTableAndStreamInfo()
org.wso2.carbon.event.simulator.stub.types.StreamDefinitionInfoDto[]	getAllEventStreamInfoDto()
void	pauseEventsViaFile(String fileName)
void	resumeEventsViaFile(String fileName)
boolean	saveDataSourceConfigDetails(String eventStreamDataSourceColumnNamesAndTypeInfo)
boolean	sendConfigDetails(String fileName, String streamId, String separateChar, long delayBetweenEventsInMilies)
boolean	sendDBConfigFileNameToSimulate(String fileName)
void	sendEvent(org.wso2.carbon.event.simulator.stub.types.EventDto eventDto)
void	sendEventsViaFile(String fileName)
String	testSimulateRDBMSDataSourceConnection(String eventStreamDataSourceColumnNamesAndTypeInfo)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventSimulatorAdminServiceClient

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

Throws:

org.apache.axis2.AxisFault

EventSimulatorAdminServiceClient

public EventSimulatorAdminServiceClient(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()

sendEvent

public void sendEvent(org.wso2.carbon.event.simulator.stub.types.EventDto eventDto)
               throws RemoteException

Throws:

RemoteException

getAllEventStreamInfoDto

public org.wso2.carbon.event.simulator.stub.types.StreamDefinitionInfoDto[] getAllEventStreamInfoDto()
                                                                                              throws RemoteException

Throws:

RemoteException

testSimulateRDBMSDataSourceConnection

public String testSimulateRDBMSDataSourceConnection(String eventStreamDataSourceColumnNamesAndTypeInfo)
                                             throws RemoteException

Throws:

RemoteException

getAllDataSourceTableAndStreamInfo

public org.wso2.carbon.event.simulator.stub.types.DataSourceTableAndStreamInfoDto[] getAllDataSourceTableAndStreamInfo()
                                                                                                                throws RemoteException

Throws:

RemoteException

saveDataSourceConfigDetails

public boolean saveDataSourceConfigDetails(String eventStreamDataSourceColumnNamesAndTypeInfo)
                                    throws RemoteException

Throws:

RemoteException

sendDBConfigFileNameToSimulate

public boolean sendDBConfigFileNameToSimulate(String fileName)
                                       throws RemoteException

Throws:

RemoteException

deleteDBConfigFile

public boolean deleteDBConfigFile(String fileName)
                           throws RemoteException

Throws:

RemoteException

sendConfigDetails

public boolean sendConfigDetails(String fileName,
                                 String streamId,
                                 String separateChar,
                                 long delayBetweenEventsInMilies)
                          throws RemoteException

Throws:

RemoteException

sendEventsViaFile

public void sendEventsViaFile(String fileName)
                       throws RemoteException

Throws:

RemoteException

pauseEventsViaFile

public void pauseEventsViaFile(String fileName)
                        throws RemoteException

Throws:

RemoteException

resumeEventsViaFile

public void resumeEventsViaFile(String fileName)
                         throws RemoteException

Throws:

RemoteException

deleteFile

public boolean deleteFile(String fileName)
                   throws RemoteException

Throws:

RemoteException