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 <S, T> void setField(final S source, final String field, final Consumer<T> t, T value) {
         try {
             t.accept(value);