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

refactor(Worker): update error message

Browse source
This commit is contained in:
glarwood 2019-03-22 18:10:29 +00:00
parent 8642f0b40b
commit 4ffc50a8ff
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -522,7 +522,7 @@ public class Worker implements Runnable {
Thread.sleep(idleTimeInMilliseconds);
} catch (Exception e) {
if (causedByStreamRecordProcessingError(e))
throw new RuntimeException("Failing worker after irrecoverable failure in processing records");
throw new RuntimeException("Failing worker after irrecoverable failure: " + e.getMessage());
if (exitOnFailure && retries.getAndIncrement() > MAX_RETRIES)
throw new RuntimeException("Failing after " + MAX_RETRIES + " attempts", e);