You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2020/07/31 05:24:01 UTC
[camel] branch master updated: Fixed CS
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 <cl...@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();