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

Fixed failing unit test

Browse source
This commit is contained in:
Monishkumar Gajendran 2021-10-05 10:15:33 -07:00
parent b5801edc1d
commit b72b9b01ca
3 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -278,7 +278,6 @@ public class PrefetchRecordsPublisher implements RecordsPublisher {
// (Re-)Cancel if current thread also interrupted // (Re-)Cancel if current thread also interrupted
executorService.shutdownNow(); executorService.shutdownNow();
} }
executorService.shutdownNow();
started = false; started = false;
} }

2
amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisherIntegrationTest.java
View file

@ -254,7 +254,7 @@ public class PrefetchRecordsPublisherIntegrationTest {
public void shutdown() { public void shutdown() {
getRecordsCache.shutdown(); getRecordsCache.shutdown();
sleep(100L); sleep(100L);
verify(executorService).shutdownNow(); verify(executorService).shutdown();
// verify(getRecordsRetrievalStrategy).shutdown(); // verify(getRecordsRetrievalStrategy).shutdown();
} }

2
amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisherTest.java
View file

@ -770,7 +770,7 @@ public class PrefetchRecordsPublisherTest {
@After @After
public void shutdown() { public void shutdown() {
getRecordsCache.shutdown(); getRecordsCache.shutdown();
verify(executorService).shutdownNow(); verify(executorService).shutdown();
} }
private void sleep(long millis) { private void sleep(long millis) {