org.wso2.das4is.integration.common.clients

Class EventPublisherAdminServiceClient

java.lang.Object

org.wso2.das4is.integration.common.clients.EventPublisherAdminServiceClient

public class EventPublisherAdminServiceClient
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
org.apache.axis2.client.ServiceClient	_getServiceClient()
void	addEventPublisherConfiguration(String eventPublisherConfigXml)
void	addJSONEventPublisherConfiguration(String eventPublisherName, String streamNameWithVersion, String eventAdapterType, String jsonData, org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration, String dataFrom, boolean mappingEnabled)
boolean	addMapEventPublisherConfiguration(String eventPublisherName, String streamNameWithVersion, String eventAdapterType, org.wso2.carbon.event.publisher.stub.types.EventMappingPropertyDto[] mapData, org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration, boolean mappingEnabled)
boolean	addTextEventPublisherConfiguration(String eventPublisherName, String streamNameWithVersion, String eventAdapterType, String textData, org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration, String dataFrom, boolean mappingEnabled)
void	addWso2EventPublisherConfiguration(String eventPublisherName, String streamNameWithVersion, String eventAdapterType, org.wso2.carbon.event.publisher.stub.types.EventMappingPropertyDto[] metaData, org.wso2.carbon.event.publisher.stub.types.EventMappingPropertyDto[] correlationData, org.wso2.carbon.event.publisher.stub.types.EventMappingPropertyDto[] payloadData, org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration, boolean mappingEnabled, String toStreamNameWithVersion)
void	addXMLEventPublisherConfiguration(String eventPublisherName, String streamNameWithVersion, String eventAdapterType, String textData, org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration, String dataFrom, boolean mappingEnabled)
org.wso2.carbon.event.publisher.stub.types.EventPublisherConfigurationDto	getActiveEventPublisherConfiguration(String eventPublisherName)
String	getActiveEventPublisherConfigurationContent(String eventPublisherName)
int	getActiveEventPublisherCount()
org.wso2.carbon.event.publisher.stub.types.EventPublisherConfigurationInfoDto[]	getAllStreamSpecificActiveEventPublisherConfigurations(String streamId)
org.wso2.carbon.event.publisher.stub.types.EventPublisherConfigurationDto	getEventPublisherConfiguration(String eventPublisherName)
int	getEventPublisherCount()
String	getInactiveEventPublisherConfigurationContent(String eventPublisherFileName)
int	getInactiveEventPublisherCount()
void	removeActiveEventPublisherConfiguration(String eventPublisherName)
void	removeInactiveEventPublisherConfiguration(String fileName)
void	setStatisticsEnabled(String eventPublisherConfiguration, boolean flag)
void	testConnection(String eventPublisherName, String eventPublisherType, org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration, String messageFormat)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventPublisherAdminServiceClient

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

Throws:

org.apache.axis2.AxisFault

EventPublisherAdminServiceClient

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

getActiveEventPublisherCount

public int getActiveEventPublisherCount()
                                 throws RemoteException

Throws:

RemoteException

getInactiveEventPublisherCount

public int getInactiveEventPublisherCount()
                                   throws RemoteException

Throws:

RemoteException

getEventPublisherCount

public int getEventPublisherCount()
                           throws RemoteException

Throws:

RemoteException

addWso2EventPublisherConfiguration

public void addWso2EventPublisherConfiguration(String eventPublisherName,
                                               String streamNameWithVersion,
                                               String eventAdapterType,
                                               org.wso2.carbon.event.publisher.stub.types.EventMappingPropertyDto[] metaData,
                                               org.wso2.carbon.event.publisher.stub.types.EventMappingPropertyDto[] correlationData,
                                               org.wso2.carbon.event.publisher.stub.types.EventMappingPropertyDto[] payloadData,
                                               org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration,
                                               boolean mappingEnabled,
                                               String toStreamNameWithVersion)
                                        throws RemoteException

Throws:

RemoteException

addMapEventPublisherConfiguration

public boolean addMapEventPublisherConfiguration(String eventPublisherName,
                                                 String streamNameWithVersion,
                                                 String eventAdapterType,
                                                 org.wso2.carbon.event.publisher.stub.types.EventMappingPropertyDto[] mapData,
                                                 org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration,
                                                 boolean mappingEnabled)
                                          throws RemoteException

Throws:

RemoteException

addXMLEventPublisherConfiguration

public void addXMLEventPublisherConfiguration(String eventPublisherName,
                                              String streamNameWithVersion,
                                              String eventAdapterType,
                                              String textData,
                                              org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration,
                                              String dataFrom,
                                              boolean mappingEnabled)
                                       throws RemoteException

Throws:

RemoteException

addTextEventPublisherConfiguration

public boolean addTextEventPublisherConfiguration(String eventPublisherName,
                                                  String streamNameWithVersion,
                                                  String eventAdapterType,
                                                  String textData,
                                                  org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration,
                                                  String dataFrom,
                                                  boolean mappingEnabled)
                                           throws RemoteException

Throws:

RemoteException

addJSONEventPublisherConfiguration

public void addJSONEventPublisherConfiguration(String eventPublisherName,
                                               String streamNameWithVersion,
                                               String eventAdapterType,
                                               String jsonData,
                                               org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration,
                                               String dataFrom,
                                               boolean mappingEnabled)
                                        throws RemoteException

Throws:

RemoteException

addEventPublisherConfiguration

public void addEventPublisherConfiguration(String eventPublisherConfigXml)
                                    throws RemoteException

Throws:

RemoteException

removeActiveEventPublisherConfiguration

public void removeActiveEventPublisherConfiguration(String eventPublisherName)
                                             throws RemoteException

Throws:

RemoteException

removeInactiveEventPublisherConfiguration

public void removeInactiveEventPublisherConfiguration(String fileName)
                                               throws RemoteException

Throws:

RemoteException

getEventPublisherConfiguration

public org.wso2.carbon.event.publisher.stub.types.EventPublisherConfigurationDto getEventPublisherConfiguration(String eventPublisherName)
                                                                                                         throws RemoteException

Throws:

RemoteException

getActiveEventPublisherConfigurationContent

public String getActiveEventPublisherConfigurationContent(String eventPublisherName)
                                                   throws RemoteException

Throws:

RemoteException

setStatisticsEnabled

public void setStatisticsEnabled(String eventPublisherConfiguration,
                                 boolean flag)
                          throws RemoteException

Throws:

RemoteException

getActiveEventPublisherConfiguration

public org.wso2.carbon.event.publisher.stub.types.EventPublisherConfigurationDto getActiveEventPublisherConfiguration(String eventPublisherName)
                                                                                                               throws RemoteException

Throws:

RemoteException

getInactiveEventPublisherConfigurationContent

public String getInactiveEventPublisherConfigurationContent(String eventPublisherFileName)
                                                     throws RemoteException

Throws:

RemoteException

testConnection

public void testConnection(String eventPublisherName,
                           String eventPublisherType,
                           org.wso2.carbon.event.publisher.stub.types.BasicOutputAdapterPropertyDto[] outputPropertyConfiguration,
                           String messageFormat)
                    throws RemoteException

Throws:

RemoteException

getAllStreamSpecificActiveEventPublisherConfigurations

public org.wso2.carbon.event.publisher.stub.types.EventPublisherConfigurationInfoDto[] getAllStreamSpecificActiveEventPublisherConfigurations(String streamId)
                                                                                                                                       throws RemoteException

Throws:

RemoteException