net.bluemind.core.backup.continuous.store

Interface TopicSubscriber

All Known Implementing Classes:

KafkaTopicSubscriber

public interface TopicSubscriber

Method Summary

Modifier and Type	Method and Description
ITopicStore.IResumeToken	parseToken(io.vertx.core.json.JsonObject js)
ITopicStore.IResumeToken	subscribe(java.util.function.BiConsumer<byte[],byte[]> handler)
ITopicStore.IResumeToken	subscribe(ITopicStore.IResumeToken index, java.util.function.BiConsumer<byte[],byte[]> handler)
ITopicStore.IResumeToken	subscribe(ITopicStore.IResumeToken index, java.util.function.BiConsumer<byte[],byte[]> handler, IRecordStarvationStrategy strat)
java.lang.String	topicName()

Method Detail

topicName

java.lang.String topicName()

parseToken

ITopicStore.IResumeToken parseToken(io.vertx.core.json.JsonObject js)

subscribe

ITopicStore.IResumeToken subscribe(java.util.function.BiConsumer<byte[],byte[]> handler)

subscribe

ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken index,
                                   java.util.function.BiConsumer<byte[],byte[]> handler)

subscribe

ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken index,
                                   java.util.function.BiConsumer<byte[],byte[]> handler,
                                   IRecordStarvationStrategy strat)