org.wso2.carbon.event.stream.admin

Class EventStreamAdminService

java.lang.Object

org.wso2.carbon.core.AbstractAdmin

org.wso2.carbon.event.stream.admin.EventStreamAdminService

public class EventStreamAdminService
extends org.wso2.carbon.core.AbstractAdmin

Field Summary

Fields inherited from class org.wso2.carbon.core.AbstractAdmin

axisConfig, configurationContext

Constructor Summary

Constructors

Constructor and Description
EventStreamAdminService()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addEventStreamDefinitionAsDto(EventStreamDefinitionDto eventStreamDefinitionDto)
boolean	addEventStreamDefinitionAsString(String streamStringDefinition)
String	convertEventStreamDefinitionDtoToString(EventStreamDefinitionDto eventStreamDefinitionDto)
EventStreamDefinitionDto	convertStringToEventStreamDefinitionDto(String streamStringDefinition)
boolean	editEventStreamDefinitionAsDto(EventStreamDefinitionDto eventStreamDefinitionDto, String oldStreamId)
boolean	editEventStreamDefinitionAsString(String streamStringDefinition, String oldStreamId)
String	generateSampleEvent(String streamId, String eventType)
EventStreamInfoDto[]	getAllEventStreamDefinitionDto()
String	getStreamDefinitionAsString(String streamId)
EventStreamDefinitionDto	getStreamDefinitionDto(String streamId)
String[]	getStreamDetailsForStreamId(String streamId)
String[]	getStreamNames()
boolean	removeEventStreamDefinition(String eventStreamName, String eventStreamVersion)

Methods inherited from class org.wso2.carbon.core.AbstractAdmin

getAxisConfig, getConfigContext, getConfigSystemRegistry, getConfigUserRegistry, getGovernanceRegistry, getGovernanceSystemRegistry, getGovernanceUserRegistry, getHttpSession, getLocalRepo, getRegistry, getTenantDomain, getUsername, getUserRealm, setConfigurationContext, setPermissionUpdateTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamAdminService

public EventStreamAdminService()

Method Detail

addEventStreamDefinitionAsDto

public boolean addEventStreamDefinitionAsDto(EventStreamDefinitionDto eventStreamDefinitionDto)
                                      throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

addEventStreamDefinitionAsString

public boolean addEventStreamDefinitionAsString(String streamStringDefinition)
                                         throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

editEventStreamDefinitionAsString

public boolean editEventStreamDefinitionAsString(String streamStringDefinition,
                                        String oldStreamId)
                                          throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

editEventStreamDefinitionAsDto

public boolean editEventStreamDefinitionAsDto(EventStreamDefinitionDto eventStreamDefinitionDto,
                                     String oldStreamId)
                                       throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

removeEventStreamDefinition

public boolean removeEventStreamDefinition(String eventStreamName,
                                  String eventStreamVersion)
                                    throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

getAllEventStreamDefinitionDto

public EventStreamInfoDto[] getAllEventStreamDefinitionDto()
                                                    throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

getStreamNames

public String[] getStreamNames()
                        throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

getStreamDetailsForStreamId

public String[] getStreamDetailsForStreamId(String streamId)
                                     throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

generateSampleEvent

public String generateSampleEvent(String streamId,
                         String eventType)
                           throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

getStreamDefinitionAsString

public String getStreamDefinitionAsString(String streamId)
                                   throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

getStreamDefinitionDto

public EventStreamDefinitionDto getStreamDefinitionDto(String streamId)
                                                throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

convertEventStreamDefinitionDtoToString

public String convertEventStreamDefinitionDtoToString(EventStreamDefinitionDto eventStreamDefinitionDto)
                                               throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

convertStringToEventStreamDefinitionDto

public EventStreamDefinitionDto convertStringToEventStreamDefinitionDto(String streamStringDefinition)
                                                                 throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault