From 9e102af3ddc808de2dc8890f6ba95c372ce82fe1 Mon Sep 17 00:00:00 2001 From: bencvdb Date: Wed, 26 Jun 2019 09:35:59 -0700 Subject: [PATCH] feature(worker): make Worker#getLeaseCoordinator public --- .../services/kinesis/clientlibrary/lib/worker/Worker.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 a4aafb86..0dbc1e27 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 */ - KinesisClientLibLeaseCoordinator getLeaseCoordinator() { + public KinesisClientLibLeaseCoordinator getLeaseCoordinator() { return leaseCoordinator; } @@ -1030,6 +1030,10 @@ 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);