org.wso2.siddhi.core.stream.output

Class Callback

java.lang.Object

org.wso2.siddhi.core.stream.output.Callback

All Implemented Interfaces:

Runnable, StreamReceiver

public abstract class Callback
extends Object
implements Runnable, StreamReceiver

Constructor Summary

Constructors

Constructor and Description
Callback()

Method Summary

Methods

Modifier and Type	Method and Description
Object	getData(Object[] eventData, int eventPosition, int dataPosition)
String	getStreamId()
abstract void	receive(long timeStamp, Object[] newEventData, Object[] removeEventData, Object[] faultEventData)
void	receive(StreamEvent event)
void	run()
void	setStreamId(String streamId)
void	setThreadPoolExecutor(ThreadPoolExecutor threadPoolExecutor)
String	toString(long timeStamp, Object[] newEventData, Object[] removeEventData, Object[] faultEventData)

Methods inherited from class java.lang.Object

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

Constructor Detail

Callback

public Callback()

Method Detail

setThreadPoolExecutor

public void setThreadPoolExecutor(ThreadPoolExecutor threadPoolExecutor)

toString

public String toString(long timeStamp,
              Object[] newEventData,
              Object[] removeEventData,
              Object[] faultEventData)

getData

public Object getData(Object[] eventData,
             int eventPosition,
             int dataPosition)

receive

public void receive(StreamEvent event)
             throws InterruptedException

Specified by:

receive in interface StreamReceiver

Throws:

InterruptedException

run

public void run()

Specified by:

run in interface Runnable

receive

public abstract void receive(long timeStamp,
           Object[] newEventData,
           Object[] removeEventData,
           Object[] faultEventData)

setStreamId

public void setStreamId(String streamId)

getStreamId

public String getStreamId()

Specified by:

getStreamId in interface StreamReceiver