org.wso2.siddhi.core.stream.recevier.sequence

Class SequenceStreamReceiver

java.lang.Object

org.wso2.siddhi.core.stream.recevier.sequence.SequenceStreamReceiver

All Implemented Interfaces:

Runnable, StreamReceiver, StreamElement

public class SequenceStreamReceiver
extends Object
implements StreamReceiver, StreamElement, Runnable

Constructor Summary

Constructors

Constructor and Description
SequenceStreamReceiver(String streamId, List<SequenceSingleStreamReceiver> sequenceSingleStreamReceiverList, ThreadPoolExecutor threadPoolExecutor)

Method Summary

Methods

Modifier and Type	Method and Description
List<SequenceSingleStreamReceiver>	getSequenceSingleStreamReceiverList()
String	getStreamId()
SchedulerQueue<StreamEvent>	getWindow()
void	receive(StreamEvent event)
void	run()
void	setOtherStreamReceivers(List<SequenceSingleStreamReceiver> otherStreamReceiverList)

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceStreamReceiver

public SequenceStreamReceiver(String streamId,
                      List<SequenceSingleStreamReceiver> sequenceSingleStreamReceiverList,
                      ThreadPoolExecutor threadPoolExecutor)

Method Detail

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

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

setOtherStreamReceivers

public void setOtherStreamReceivers(List<SequenceSingleStreamReceiver> otherStreamReceiverList)

getSequenceSingleStreamReceiverList

public List<SequenceSingleStreamReceiver> getSequenceSingleStreamReceiverList()