net.bluemind.core.backup.store.kafka

Class ParallelStarvationHandler

java.lang.Object

net.bluemind.core.backup.store.kafka.ParallelStarvationHandler

All Implemented Interfaces:

IRecordStarvationStrategy

public class ParallelStarvationHandler
extends java.lang.Object
implements IRecordStarvationStrategy

Create IRecordStarvationStrategy "workers" for dealing with starvation in multiple consumers. We will trigger the parent IRecordStarvationStrategy only if all workers starved in the last second.

Nested Class Summary

Nested classes/interfaces inherited from interface net.bluemind.core.backup.continuous.IRecordStarvationStrategy

IRecordStarvationStrategy.ExpectedBehaviour

Constructor Summary

Constructors

Constructor and Description
ParallelStarvationHandler(IRecordStarvationStrategy starved, int worker)

Method Summary

Modifier and Type	Method and Description
void	onRecordsReceived(io.vertx.core.json.JsonObject metas)
IRecordStarvationStrategy.ExpectedBehaviour	onStarvation(io.vertx.core.json.JsonObject infos)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface net.bluemind.core.backup.continuous.IRecordStarvationStrategy

checkpoint

Constructor Detail

ParallelStarvationHandler

public ParallelStarvationHandler(IRecordStarvationStrategy starved,
                                 int worker)

Method Detail

onRecordsReceived

public void onRecordsReceived(io.vertx.core.json.JsonObject metas)

Specified by:

onRecordsReceived in interface IRecordStarvationStrategy

onStarvation

public IRecordStarvationStrategy.ExpectedBehaviour onStarvation(io.vertx.core.json.JsonObject infos)

Specified by:

onStarvation in interface IRecordStarvationStrategy