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

restore exception catch in woker run method to maintain old behavior

Browse source
This commit is contained in:
Thuan Duong-Ba 2020-01-20 10:24:07 -08:00
parent 6ca825e5c5
commit 28d4416953
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -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();