Modifier and Type | Field and Description |
---|---|
protected InputProcessor |
inputProcessor |
protected InputProcessor |
pausedInputPublisher |
protected SiddhiAppContext |
siddhiAppContext |
protected String |
streamId |
protected int |
streamIndex |
Constructor and Description |
---|
InputHandler(String streamId,
int streamIndex,
InputProcessor inputProcessor,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
String |
getStreamId() |
void |
send(Event event) |
void |
send(Event[] events) |
void |
send(long timestamp,
Object[] data) |
void |
send(Object[] data) |
protected String streamId
protected int streamIndex
protected InputProcessor inputProcessor
protected SiddhiAppContext siddhiAppContext
protected InputProcessor pausedInputPublisher
public InputHandler(String streamId, int streamIndex, InputProcessor inputProcessor, SiddhiAppContext siddhiAppContext)
public String getStreamId()
public void send(Object[] data) throws InterruptedException
InterruptedException
public void send(long timestamp, Object[] data) throws InterruptedException
InterruptedException
public void send(Event event) throws InterruptedException
InterruptedException
public void send(Event[] events) throws InterruptedException
InterruptedException
Copyright © 2021. All rights reserved.