org.wso2.siddhi.core.stream.recevier.pattern

Class PatternStreamReceiver

java.lang.Object

org.wso2.siddhi.core.stream.recevier.pattern.PatternStreamReceiver

All Implemented Interfaces:

Runnable, StreamReceiver, StreamElement

public class PatternStreamReceiver
extends Object
implements StreamReceiver, StreamElement, Runnable

Constructor Summary

Constructors

Constructor and Description
PatternStreamReceiver(String streamId, List<PatternSingleStreamReceiver> patternSingleStreamReceiverList, 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

PatternStreamReceiver

public PatternStreamReceiver(String streamId,
                     List<PatternSingleStreamReceiver> patternSingleStreamReceiverList,
                     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