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

Update based on comments

Browse source
This commit is contained in:
Meher Mankikar 2023-08-03 10:35:58 -07:00
parent 94dff28f5f
commit 7773af50d0
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java
View file

@ -183,7 +183,7 @@ public class TestConsumer {
this.consumerFuture = consumerExecutor.schedule(scheduler, 0, TimeUnit.SECONDS); this.consumerFuture = consumerExecutor.schedule(scheduler, 0, TimeUnit.SECONDS);
} }
public void stopProducer() { private void stopProducer() {
log.info("Cancelling producer and shutting down executor."); log.info("Cancelling producer and shutting down executor.");
if (producerFuture != null) { if (producerFuture != null) {
producerFuture.cancel(false); producerFuture.cancel(false);