org.wso2.siddhi.core.stream

Class StreamJunction

java.lang.Object

org.wso2.siddhi.core.stream.StreamJunction

public class StreamJunction
extends Object

Constructor Summary

Constructors

Constructor and Description
StreamJunction(StreamDefinition streamDefinition)

Method Summary

Methods

Modifier and Type	Method and Description
void	addEventFlow(StreamReceiver streamReceiver)
void	send(StreamEvent streamEvent)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamJunction

public StreamJunction(StreamDefinition streamDefinition)

Method Detail

send

public void send(StreamEvent streamEvent)
          throws InterruptedException

Throws:

InterruptedException

addEventFlow

public void addEventFlow(StreamReceiver streamReceiver)