public abstract class StreamCallback extends Object implements StreamJunction.Receiver
StreamJunction
. This class should be extended if one intends
to get events from a Siddhi Stream.Constructor and Description |
---|
StreamCallback() |
Modifier and Type | Method and Description |
---|---|
io.siddhi.query.api.definition.AbstractDefinition |
getStreamDefinition() |
String |
getStreamId() |
void |
receive(ComplexEvent complexEvent) |
void |
receive(Event event) |
abstract void |
receive(Event[] events) |
void |
receive(List<Event> events) |
void |
receive(long timestamp,
Object[] data) |
void |
receiveEvents(Event[] events) |
void |
setContext(SiddhiAppContext siddhiAppContext) |
void |
setStreamDefinition(io.siddhi.query.api.definition.AbstractDefinition streamDefinition) |
void |
setStreamId(String streamId) |
void |
startProcessing() |
void |
stopProcessing() |
Map<String,Object> |
toMap(Event event) |
Map<String,Object>[] |
toMap(Event[] events) |
public String getStreamId()
getStreamId
in interface StreamJunction.Receiver
public void setStreamId(String streamId)
public io.siddhi.query.api.definition.AbstractDefinition getStreamDefinition()
public void setStreamDefinition(io.siddhi.query.api.definition.AbstractDefinition streamDefinition)
public void setContext(SiddhiAppContext siddhiAppContext)
public void receive(ComplexEvent complexEvent)
receive
in interface StreamJunction.Receiver
public void receive(Event event)
receive
in interface StreamJunction.Receiver
public void receive(List<Event> events)
receive
in interface StreamJunction.Receiver
public void receive(long timestamp, Object[] data)
receive
in interface StreamJunction.Receiver
public void receiveEvents(Event[] events)
public abstract void receive(Event[] events)
receive
in interface StreamJunction.Receiver
public void startProcessing()
public void stopProcessing()
Copyright © 2021. All rights reserved.