From 9def9134531e5817fe25e23e91bb0ff362e24e5d Mon Sep 17 00:00:00 2001 From: Sahil Palvia Date: Mon, 18 Sep 2017 15:02:06 -0700 Subject: [PATCH] Reverting back to the interface --- ...ecordsRetrieverDaemon.java => GetRecordsRetriever.java} | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) rename src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/{GetRecordsRetrieverDaemon.java => GetRecordsRetriever.java} (62%) diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/GetRecordsRetrieverDaemon.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/GetRecordsRetriever.java similarity index 62% rename from src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/GetRecordsRetrieverDaemon.java rename to src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/GetRecordsRetriever.java index 959c69ba..2d8e318e 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/GetRecordsRetrieverDaemon.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/GetRecordsRetriever.java @@ -7,9 +7,6 @@ import java.util.concurrent.Callable; /** * This class uses the GetRecordsRetrievalStrategy class to retrieve the next set of records and update the cache. */ -public class GetRecordsRetrieverDaemon implements Callable { - @Override - public GetRecordsResult call() throws Exception { - return null; - } +public interface GetRecordsRetriever { + GetRecordsResult getNextRecords(int maxRecords) }