software.amazon.kinesis.retrieval.polling

Class PrefetchRecordsPublisher.PrefetchCounters

java.lang.Object

software.amazon.kinesis.retrieval.polling.PrefetchRecordsPublisher.PrefetchCounters

Enclosing class:

PrefetchRecordsPublisher

protected class PrefetchRecordsPublisher.PrefetchCounters
extends Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PrefetchCounters()

Method Summary

Modifier and Type	Method and Description
void	added(ProcessRecordsInput result)
void	removed(ProcessRecordsInput result)
boolean	shouldGetNewRecords()
String	toString()
void	waitForConsumer()

Methods inherited from class java.lang.Object

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

Constructor Detail

PrefetchCounters

protected PrefetchCounters()

Method Detail

added

public void added(ProcessRecordsInput result)

removed

public void removed(ProcessRecordsInput result)

waitForConsumer

public void waitForConsumer()
                     throws InterruptedException

Throws:

InterruptedException

shouldGetNewRecords

public boolean shouldGetNewRecords()

toString

public String toString()

Overrides:

toString in class Object