CAMEL-15153: fixing KinesisConsumerClosedShardWithFailTest

apache · Jun 6, 2020 · 16ef060 · 16ef060
1 parent 466ffd3
commit 16ef060
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/.../java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java b/.../java/org/apache/camel/component/aws2/kinesis/KinesisConsumerClosedShardWithFailTest.java
@@ -22,6 +22,7 @@
 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 void itObtainsAShardIteratorOnFirstPoll() throws Exception {
         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));
     }
 }