From 2b244a67b5d0f7b9c424712fc61cba369e53512a Mon Sep 17 00:00:00 2001 From: Stefan Meiwald Date: Fri, 23 Jan 2015 14:41:20 +0100 Subject: [PATCH] React to shutdown signal during initializing attempts --- .../services/kinesis/clientlibrary/lib/worker/Worker.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 38abe856..72d66356 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 @@ -373,7 +373,7 @@ public class Worker implements Runnable { boolean isDone = false; Exception lastException = null; - for (int i = 0; (!isDone) && (i < MAX_INITIALIZATION_ATTEMPTS); i++) { + for (int i = 0; (!isDone) && (i < MAX_INITIALIZATION_ATTEMPTS) && (!shutdown); i++) { try { LOG.info("Initialization attempt " + (i + 1)); LOG.info("Initializing LeaseCoordinator"); @@ -413,7 +413,7 @@ public class Worker implements Runnable { } } - if (!isDone) { + if (!isDone && (lastException != null)) { throw new RuntimeException(lastException); } }