diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java index 60bc15cd..b4d12e79 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java @@ -468,7 +468,7 @@ public class Worker implements Runnable { /** * @return the leaseCoordinator */ - public KinesisClientLibLeaseCoordinator getLeaseCoordinator() { + KinesisClientLibLeaseCoordinator getLeaseCoordinator() { return leaseCoordinator; } @@ -1033,10 +1033,6 @@ public class Worker implements Runnable { return new WorkerThreadPoolExecutor(threadFactory); } - public ExecutorService returnExecutorService() { - return this.executorService; - } - private static void setField(final S source, final String field, final Consumer t, T value) { try { t.accept(value);