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<GetRecordsResult> {
-    @Override
-    public GetRecordsResult call() throws Exception {
-        return null;
-    }
+public interface GetRecordsRetriever {
+    GetRecordsResult getNextRecords(int maxRecords)
 }