org.wso2.carbon.analytics.datasink.subscriber

Class AnalyticsWSO2EventConsumer

java.lang.Object

org.wso2.carbon.analytics.datasink.subscriber.AnalyticsWSO2EventConsumer

All Implemented Interfaces:

org.wso2.carbon.event.stream.manager.core.WSO2EventConsumer, org.wso2.carbon.event.stream.manager.core.WSO2EventListConsumer

public class AnalyticsWSO2EventConsumer
extends Object
implements org.wso2.carbon.event.stream.manager.core.WSO2EventListConsumer

Constructor Summary

Constructors

Constructor and Description
AnalyticsWSO2EventConsumer(String streamId, int tenantId)

Method Summary

Methods

Modifier and Type	Method and Description
String	getStreamId()
void	onAddDefinition(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)
void	onEvent(org.wso2.carbon.databridge.commons.Event event)
void	onEventList(List<org.wso2.carbon.databridge.commons.Event> eventList)
void	onRemoveDefinition(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsWSO2EventConsumer

public AnalyticsWSO2EventConsumer(String streamId,
                          int tenantId)

Method Detail

getStreamId

public String getStreamId()

Specified by:

getStreamId in interface org.wso2.carbon.event.stream.manager.core.WSO2EventConsumer

onEvent

public void onEvent(org.wso2.carbon.databridge.commons.Event event)

Specified by:

onEvent in interface org.wso2.carbon.event.stream.manager.core.WSO2EventConsumer

onEventList

public void onEventList(List<org.wso2.carbon.databridge.commons.Event> eventList)

Specified by:

onEventList in interface org.wso2.carbon.event.stream.manager.core.WSO2EventListConsumer

onAddDefinition

public void onAddDefinition(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)

Specified by:

onAddDefinition in interface org.wso2.carbon.event.stream.manager.core.WSO2EventConsumer

onRemoveDefinition

public void onRemoveDefinition(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)

Specified by:

onRemoveDefinition in interface org.wso2.carbon.event.stream.manager.core.WSO2EventConsumer