public interface ILiveStream
Modifier and Type | Method and Description |
---|---|
java.lang.String |
domainUid() |
java.lang.String |
fullName() |
java.lang.String |
installationId() |
ITopicStore.IResumeToken |
parse(io.vertx.core.json.JsonObject js) |
ITopicStore.IResumeToken |
subscribe(io.vertx.core.Handler<DataElement> handler) |
ITopicStore.IResumeToken |
subscribe(ITopicStore.IResumeToken startOffset,
io.vertx.core.Handler<DataElement> handler) |
ITopicStore.IResumeToken |
subscribe(ITopicStore.IResumeToken startOffset,
io.vertx.core.Handler<DataElement> handler,
IRecordStarvationStrategy onStarve) |
java.lang.String fullName()
ITopicStore.IResumeToken parse(io.vertx.core.json.JsonObject js)
ITopicStore.IResumeToken subscribe(io.vertx.core.Handler<DataElement> handler)
ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken startOffset, io.vertx.core.Handler<DataElement> handler)
ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken startOffset, io.vertx.core.Handler<DataElement> handler, IRecordStarvationStrategy onStarve)
java.lang.String installationId()
java.lang.String domainUid()
Copyright © 2023. All Rights Reserved.