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 b4d12e79..7ce6f104 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 @@ -493,8 +493,7 @@ public class Worker implements Runnable { while (!shouldShutdown()) { runProcessLoop(); } - } - finally { + } finally { finalShutdown(); LOG.info("Worker loop is complete. Exiting from worker."); }