This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push: new aeb9df5 Fixed CS aeb9df5 is described below commit aeb9df5c6dfd825d898b462d1e7ad0cfa93fe745 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Fri Jul 31 07:23:33 2020 +0200 Fixed CS --- .../aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java | 4 ++-- .../org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java index 89fa8c3..f5c6186 100644 --- a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java +++ b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java @@ -173,7 +173,7 @@ public class KinesisConsumerClosedShardWithSilentTest { .thenReturn(new GetRecordsResult() .withNextShardIterator("nextShardIterator") .withRecords(new Record().withSequenceNumber("1"), new Record().withSequenceNumber("2")) - ); + ); int messageCount = undertest.poll(); @@ -197,7 +197,7 @@ public class KinesisConsumerClosedShardWithSilentTest { .withApproximateArrivalTimestamp(new Date(42)) .withPartitionKey(partitionKey) ) - ); + ); undertest.poll(); diff --git a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java index f9d8812..de531b4 100644 --- a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java +++ b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerTest.java @@ -173,7 +173,7 @@ public class KinesisConsumerTest { .thenReturn(new GetRecordsResult() .withNextShardIterator("nextShardIterator") .withRecords(new Record().withSequenceNumber("1"), new Record().withSequenceNumber("2")) - ); + ); int messageCount = undertest.poll(); @@ -197,7 +197,7 @@ public class KinesisConsumerTest { .withApproximateArrivalTimestamp(new Date(42)) .withPartitionKey(partitionKey) ) - ); + ); undertest.poll();