[camel] branch master updated: CAMEL-15153: fixing KinesisConsumerClosedShardWithFailTest

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[camel] branch master updated: CAMEL-15153: fixing KinesisConsumerClosedShardWithFailTest

acosentino
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


The following commit(s) were added to refs/heads/master by this push:
     new 16ef060  CAMEL-15153: fixing KinesisConsumerClosedShardWithFailTest
16ef060 is described below

commit 16ef060eef7e10044c9fd951d57efba9bdea32b2
Author: Jon Chase <[hidden email]>
AuthorDate: Sat Jun 6 07:16:27 2020 -0400

    CAMEL-15153: fixing KinesisConsumerClosedShardWithFailTest
---
 .../component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/components/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java b/components/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java
index 79d8a29..7486d1e 100644
--- a/components/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java
+++ b/components/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java
@@ -22,6 +22,7 @@ import org.apache.camel.AsyncProcessor;
 import org.apache.camel.CamelContext;
 import org.apache.camel.impl.DefaultCamelContext;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.ArgumentCaptor;
 import org.mockito.Mock;
@@ -95,6 +96,6 @@ public class KinesisConsumerClosedShardWithFailTest {
         verify(kinesisClient).getShardIterator(getShardIteratorReqCap.capture());
         assertThat(getShardIteratorReqCap.getValue().streamName(), is("streamName"));
         assertThat(getShardIteratorReqCap.getValue().shardId(), is("shardId"));
-        assertThat(getShardIteratorReqCap.getValue().shardIteratorType(), is("LATEST"));
+        assertThat(getShardIteratorReqCap.getValue().shardIteratorType(), is(ShardIteratorType.LATEST));
     }
 }