From 28d44169538298503ab2faea88c8aee93edf224f Mon Sep 17 00:00:00 2001 From: Thuan Duong-Ba Date: Mon, 20 Jan 2020 10:24:07 -0800 Subject: [PATCH] restore exception catch in woker run method to maintain old behavior --- .../services/kinesis/clientlibrary/lib/worker/Worker.java | 8 ++++++-- 1 file changed, 6 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 258ca46e..16a1ec0d 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 @@ -641,8 +641,12 @@ public class Worker implements Runnable { return; } - initialize(); - LOG.info("Starting worker loop."); + try { + initialize(); + LOG.info("Starting worker loop."); + } catch (RuntimeException e1) { + LOG.error("Could not start worker loop as worker is failed to initialize."); + } while (!shouldShutdown()) { runProcessLoop();