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

refactor(worker): broaden exception handling

Browse source
This commit is contained in:
bencvdb 2021-07-07 08:29:42 -07:00
parent f2dd16257d
commit 52199a24ee
1 changed files with 1 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -619,12 +619,11 @@ public class Worker implements Runnable {
lastException = result.getException(); lastException = result.getException();
handleMissingIncompleteLeasesException(lastException); handleMissingIncompleteLeasesException(lastException);
} }
} catch (MissingIncompleteLeasesException e) {
throw e;
} catch (LeasingException e) { } catch (LeasingException e) {
LOG.error("Caught exception when initializing LeaseCoordinator", e); LOG.error("Caught exception when initializing LeaseCoordinator", e);
lastException = e; lastException = e;
} catch (Exception e) { } catch (Exception e) {
handleMissingIncompleteLeasesException(e);
lastException = e; lastException = e;
} }