luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

React to shutdown signal during initializing attempts

Browse source
This commit is contained in:
Stefan Meiwald 2015-01-23 14:41:20 +01:00
parent 9b1549e810
commit 2b244a67b5
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java
View file

@ -373,7 +373,7 @@ public class Worker implements Runnable {
boolean isDone = false; boolean isDone = false;
Exception lastException = null; 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 { try {
LOG.info("Initialization attempt " + (i + 1)); LOG.info("Initialization attempt " + (i + 1));
LOG.info("Initializing LeaseCoordinator"); LOG.info("Initializing LeaseCoordinator");
@ -413,7 +413,7 @@ public class Worker implements Runnable {
} }
} }
if (!isDone) { if (!isDone && (lastException != null)) {
throw new RuntimeException(lastException); throw new RuntimeException(lastException);
} }
} }