org.wso2.carbon.analytics.datasink.internal.queue

Class AnalyticsEventQueueWorker

java.lang.Object

org.wso2.carbon.analytics.datasink.internal.queue.AnalyticsEventQueueWorker

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<org.wso2.carbon.databridge.commons.Event>

public class AnalyticsEventQueueWorker
extends Object
implements com.lmax.disruptor.EventHandler<org.wso2.carbon.databridge.commons.Event>

Constructor Summary

Constructors

Constructor and Description
AnalyticsEventQueueWorker(int tenantId)

Method Summary

Methods

Modifier and Type	Method and Description
void	onEvent(org.wso2.carbon.databridge.commons.Event event, long sequence, boolean endOfBatch)

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsEventQueueWorker

public AnalyticsEventQueueWorker(int tenantId)

Method Detail

onEvent

public void onEvent(org.wso2.carbon.databridge.commons.Event event,
           long sequence,
           boolean endOfBatch)
             throws Exception

Specified by:

onEvent in interface com.lmax.disruptor.EventHandler<org.wso2.carbon.databridge.commons.Event>

Throws:

Exception