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

Fix setting interrupot status after shutdown

Browse source
This commit is contained in:
Monishkumar Gajendran 2021-10-06 17:29:34 -07:00
parent 9445847447
commit c3e2980bd4
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
View file

@ -306,10 +306,10 @@ public class PrefetchRecordsPublisher implements RecordsPublisher {
} }
} }
} catch (InterruptedException e) { } catch (InterruptedException e) {
// Preserve interrupt status
Thread.currentThread().interrupt();
// (Re-)Cancel if current thread also interrupted // (Re-)Cancel if current thread also interrupted
executorService.shutdownNow(); executorService.shutdownNow();
// Preserve interrupt status
Thread.currentThread().interrupt();
} }
started = false; started = false;
} }