[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 <jch...@agari.com>
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));
     }
 }