Package | Description |
---|---|
io.siddhi.core | |
io.siddhi.core.stream | |
io.siddhi.core.stream.output.sink |
Modifier and Type | Method and Description |
---|---|
void |
SiddhiAppRuntime.addCallback(String streamId,
StreamCallback streamCallback) |
void |
SiddhiAppRuntimeImpl.addCallback(String streamId,
StreamCallback streamCallback) |
void |
SiddhiAppRuntime.removeCallback(StreamCallback streamCallback) |
void |
SiddhiAppRuntimeImpl.removeCallback(StreamCallback streamCallback) |
Modifier and Type | Method and Description |
---|---|
void |
StreamJunction.unsubscribe(StreamCallback streamCallback) |
Modifier and Type | Class and Description |
---|---|
class |
SinkCallback
Sink Callback is used to get
Event s from Siddhi Streams using
StreamJunction and send them to SinkMapper s to do the mapping. |
Copyright © 2021. All rights reserved.