org.wso2.siddhi.core.stream.recevier

Class SingleStreamReceiver

java.lang.Object

org.wso2.siddhi.core.stream.recevier.SingleStreamReceiver

All Implemented Interfaces:

Runnable, StreamReceiver, StreamElement

public class SingleStreamReceiver
extends Object
implements Runnable, StreamReceiver, StreamElement

Constructor Summary

Constructors

Constructor and Description
SingleStreamReceiver(SingleStream inputStream, StreamProcessor firstStreamProcessor, ThreadPoolExecutor threadPoolExecutor)

Method Summary

Methods

Modifier and Type	Method and Description
String	getStreamId()
SchedulerQueue<StreamEvent>	getWindow()
void	receive(StreamEvent streamEvent)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleStreamReceiver

public SingleStreamReceiver(SingleStream inputStream,
                    StreamProcessor firstStreamProcessor,
                    ThreadPoolExecutor threadPoolExecutor)

Method Detail

receive

public void receive(StreamEvent streamEvent)
             throws InterruptedException

Specified by:

receive in interface StreamReceiver

Throws:

InterruptedException

run

public void run()

Specified by:

run in interface Runnable

getStreamId

public String getStreamId()

Specified by:

getStreamId in interface StreamReceiver

Specified by:

getStreamId in interface StreamElement

getWindow

public SchedulerQueue<StreamEvent> getWindow()

Specified by:

getWindow in interface StreamElement