You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/12/21 09:35:57 UTC
[camel] branch master updated (fa740ff -> 5174816)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from fa740ff CAMEL-12089 - Camel-AWS: Kinesis consumer starts consuming data from the beginning even though the shard is in Closed state
new c4fb57f CAMEL-12089 - Polish
new 5174816 CAMEL-12089 - Fixed CS
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../camel/component/aws/kinesis/ReachedClosedStatusException.java | 2 ++
.../component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java | 2 --
2 files changed, 2 insertions(+), 2 deletions(-)
--
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <co...@camel.apache.org>'].
[camel] 02/02: CAMEL-12089 - Fixed CS
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5174816e68f11246c22bd993cf0057fb30356a1c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Dec 21 10:35:35 2017 +0100
CAMEL-12089 - Fixed CS
---
.../camel/component/aws/kinesis/ReachedClosedStatusException.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/ReachedClosedStatusException.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/ReachedClosedStatusException.java
index adce72b..805ff7b 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/ReachedClosedStatusException.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/ReachedClosedStatusException.java
@@ -19,8 +19,8 @@ package org.apache.camel.component.aws.kinesis;
public class ReachedClosedStatusException extends Exception {
private static final long serialVersionUID = -2701697822726751407L;
-
- private final String streamName;
+
+ private final String streamName;
private final String shardId;
public ReachedClosedStatusException(String streamName, String shardId) {
--
To stop receiving notification emails like this one, please contact
"commits@camel.apache.org" <co...@camel.apache.org>.
[camel] 01/02: CAMEL-12089 - Polish
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit c4fb57fae4ba3f7a876d885c8f391fb58e134f97
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Dec 21 10:31:20 2017 +0100
CAMEL-12089 - Polish
---
.../camel/component/aws/kinesis/ReachedClosedStatusException.java | 4 +++-
.../aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java | 2 --
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/ReachedClosedStatusException.java b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/ReachedClosedStatusException.java
index 8376511..adce72b 100644
--- a/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/ReachedClosedStatusException.java
+++ b/components/camel-aws/src/main/java/org/apache/camel/component/aws/kinesis/ReachedClosedStatusException.java
@@ -18,7 +18,9 @@ package org.apache.camel.component.aws.kinesis;
public class ReachedClosedStatusException extends Exception {
- private final String streamName;
+ private static final long serialVersionUID = -2701697822726751407L;
+
+ private final String streamName;
private final String shardId;
public ReachedClosedStatusException(String streamName, String shardId) {
diff --git a/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java b/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java
index f5daa8f..64f949e 100644
--- a/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java
+++ b/components/camel-aws/src/test/java/org/apache/camel/component/aws/kinesis/KinesisConsumerClosedShardWithSilentTest.java
@@ -46,8 +46,6 @@ import org.mockito.junit.MockitoJUnitRunner;
import static org.hamcrest.CoreMatchers.is;
import static org.junit.Assert.assertThat;
import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.any;
-import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
--
To stop receiving notification emails like this one, please contact
"commits@camel.apache.org" <co...@camel.apache.org>.