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

feature(worker): catch errors from runProcessLoop and shutdown

Browse source
This commit is contained in:
bencvdb 2019-06-26 13:51:50 -07:00
parent 9e102af3dd
commit d2f95cb5ed
1 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -489,13 +489,16 @@ public class Worker implements Runnable {
shutdown(); shutdown();
} }
try {
while (!shouldShutdown()) { while (!shouldShutdown()) {
runProcessLoop(); runProcessLoop();
} }
}
finally {
finalShutdown(); finalShutdown();
LOG.info("Worker loop is complete. Exiting from worker."); LOG.info("Worker loop is complete. Exiting from worker.");
} }
}
@VisibleForTesting @VisibleForTesting
void runProcessLoop() { void runProcessLoop() {