S
- current state for the Source Holderpublic abstract class SourceHandler<S extends State> extends Object implements InputEventHandlerCallback
InputHandler
.
It will do optional processing to the events before sending the events to the input handlerConstructor and Description |
---|
SourceHandler() |
Modifier and Type | Method and Description |
---|---|
String |
getId() |
InputHandler |
getInputHandler() |
abstract StateFactory |
init(String siddhiAppName,
SourceSyncCallback sourceSyncCallback,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
SiddhiAppContext siddhiAppContext) |
abstract void |
sendEvent(Event[] events,
String[] transportSyncProperties,
S state,
InputHandler inputHandler) |
void |
sendEvent(Event event,
String[] transportSyncProperties) |
abstract void |
sendEvent(Event event,
String[] transportSyncProperties,
S state,
InputHandler inputHandler) |
void |
sendEvents(Event[] events,
String[] transportSyncProperties) |
void |
setInputHandler(InputHandler inputHandler) |
public abstract StateFactory init(String siddhiAppName, SourceSyncCallback sourceSyncCallback, io.siddhi.query.api.definition.StreamDefinition streamDefinition, SiddhiAppContext siddhiAppContext)
public void sendEvent(Event event, String[] transportSyncProperties) throws InterruptedException
sendEvent
in interface InputEventHandlerCallback
InterruptedException
public void sendEvents(Event[] events, String[] transportSyncProperties) throws InterruptedException
sendEvents
in interface InputEventHandlerCallback
InterruptedException
public abstract void sendEvent(Event event, String[] transportSyncProperties, S state, InputHandler inputHandler) throws InterruptedException
InterruptedException
public abstract void sendEvent(Event[] events, String[] transportSyncProperties, S state, InputHandler inputHandler) throws InterruptedException
InterruptedException
public InputHandler getInputHandler()
public void setInputHandler(InputHandler inputHandler)
public String getId()
Copyright © 2021. All rights reserved.