From 94dff28f5f7f115edcca7721fe532fe5b82d59bf Mon Sep 17 00:00:00 2001 From: Meher Mankikar Date: Tue, 1 Aug 2023 17:26:51 -0700 Subject: [PATCH] Updated style --- .../amazon/kinesis/application/TestConsumer.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java index 67d476fa..d051a1d2 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/application/TestConsumer.java @@ -89,7 +89,8 @@ public class TestConsumer { try { startConsumer(); - // Sleep to allow the producer/consumer to run and then end the test case. If non-reshard sleep 3 minutes, else sleep 4 minutes per scale. + // Sleep to allow the producer/consumer to run and then end the test case. + // If non-reshard sleep 3 minutes, else sleep 4 minutes per scale. final int sleepMinutes = (consumerConfig.getReshardFactorList() == null) ? 3 : (4 * consumerConfig.getReshardFactorList().size()); Thread.sleep(TimeUnit.MINUTES.toMillis(sleepMinutes)); @@ -134,7 +135,12 @@ public class TestConsumer { if (consumerConfig.getReshardFactorList() != null) { log.info("----Reshard Config found: {}", consumerConfig.getReshardFactorList()); - final StreamScaler s = new StreamScaler(kinesisClient, consumerConfig.getStreamName(), consumerConfig.getReshardFactorList(), consumerConfig); + final StreamScaler s = new StreamScaler( + kinesisClient, + consumerConfig.getStreamName(), + consumerConfig.getReshardFactorList(), + consumerConfig + ); // Schedule the stream scales 4 minutes apart with 2 minute starting delay for (int i = 0; i < consumerConfig.getReshardFactorList().size(); i++) {