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

fix(worker): fix NPE

Browse source
This commit is contained in:
bencvdb 2021-07-07 09:27:14 -07:00
parent 17ad929831
commit 69e113f29d
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -574,11 +574,10 @@ public class Worker implements Runnable {
private <T extends Throwable> Optional<T> getCauseOfType(Class<T> clazz, Throwable t) { private <T extends Throwable> Optional<T> getCauseOfType(Class<T> clazz, Throwable t) {
if (t.getClass().equals(clazz)) { if (t.getClass().equals(clazz)) {
return Optional.of( (T) t); return Optional.of( (T) t);
}
if (t.getCause().getClass().equals(clazz)) {
return Optional.of( (T) t.getCause());
} else if (t.getCause() == null) { } else if (t.getCause() == null) {
return Optional.empty(); return Optional.empty();
} else if (t.getCause().getClass().equals(clazz)) {
return Optional.of( (T) t.getCause());
} }
return getCauseOfType(clazz, t.getCause()); return getCauseOfType(clazz, t.getCause());