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(ITopicStore.IResumeToken index, RecordHandler handler)
ITopicStore.IResumeToken	subscribe(ITopicStore.IResumeToken index, RecordHandler handler, IRecordStarvationStrategy strat)
ITopicStore.IResumeToken	subscribe(RecordHandler handler)
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(RecordHandler handler)

subscribe

ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken index,
                                   RecordHandler handler)

subscribe

ITopicStore.IResumeToken subscribe(ITopicStore.IResumeToken index,
                                   RecordHandler handler,
                                   IRecordStarvationStrategy strat)