org.wso2.carbon.event.stream.admin.internal

Class EventStreamAdminService

java.lang.Object

org.wso2.carbon.core.AbstractAdmin

org.wso2.carbon.event.stream.admin.internal.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
void	addEventStreamDefinitionAsDto(EventStreamDefinitionDto eventStreamDefinitionDto)
void	addEventStreamDefinitionAsString(String streamStringDefinition)
String	convertEventStreamDefinitionDtoToString(EventStreamDefinitionDto eventStreamDefinitionDto)
EventStreamDefinitionDto	convertStringToEventStreamDefinitionDto(String streamStringDefinition)
void	editEventStreamDefinitionAsDto(EventStreamDefinitionDto eventStreamDefinitionDto, String oldStreamId)
void	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()
void	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 void addEventStreamDefinitionAsDto(EventStreamDefinitionDto eventStreamDefinitionDto)
                                   throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

addEventStreamDefinitionAsString

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

Throws:

org.apache.axis2.AxisFault

editEventStreamDefinitionAsString

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

Throws:

org.apache.axis2.AxisFault

editEventStreamDefinitionAsDto

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

Throws:

org.apache.axis2.AxisFault

removeEventStreamDefinition

public void 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