[camel-quarkus] branch main updated: Fix Aws2KinesisTest.kinesis test

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new 501833a1a4 Fix Aws2KinesisTest.kinesis test
501833a1a4 is described below

commit 501833a1a4bd6c54bf357200611fbf48ed891283
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Fri Apr 8 15:16:36 2022 +0100

    Fix Aws2KinesisTest.kinesis test
    
    Fixes #3638
---
 .../component/aws2/kinesis/it/Aws2KinesisResource.java   | 16 +++++++++-------
 .../component/aws2/kinesis/it/Aws2KinesisTest.java       |  2 --
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git 
a/integration-test-groups/aws2/aws2-kinesis/src/main/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisResource.java
 
b/integration-test-groups/aws2/aws2-kinesis/src/main/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisResource.java
index df7c742768..d5f6be4f2c 100644
--- 
a/integration-test-groups/aws2/aws2-kinesis/src/main/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisResource.java
+++ 
b/integration-test-groups/aws2/aws2-kinesis/src/main/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisResource.java
@@ -16,6 +16,8 @@
  */
 package org.apache.camel.quarkus.component.aws2.kinesis.it;
 
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
 import java.net.URI;
 
 import javax.enterprise.context.ApplicationScoped;
@@ -32,7 +34,6 @@ import org.apache.camel.ConsumerTemplate;
 import org.apache.camel.ProducerTemplate;
 import org.apache.camel.component.aws2.kinesis.Kinesis2Constants;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
-import software.amazon.awssdk.services.kinesis.model.Record;
 
 @Path("/aws2-kinesis")
 @ApplicationScoped
@@ -66,13 +67,14 @@ public class Aws2KinesisResource {
 
     @Path("/receive")
     @GET
-    @Produces(MediaType.APPLICATION_JSON)
-    public String receive() {
-        Record record = consumerTemplate.receiveBody(componentUri(), 10000, 
Record.class);
-        if (record == null) {
-            return null;
+    @Produces(MediaType.TEXT_PLAIN)
+    public String receive() throws IOException {
+        try (ByteArrayInputStream result = 
consumerTemplate.receiveBody(componentUri(), 10000, 
ByteArrayInputStream.class)) {
+            if (result == null) {
+                return null;
+            }
+            return new String(result.readAllBytes());
         }
-        return record.data().asUtf8String();
     }
 
     private String componentUri() {
diff --git 
a/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTest.java
 
b/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTest.java
index e35ca1c7c9..cfc8a4358b 100644
--- 
a/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTest.java
+++ 
b/integration-test-groups/aws2/aws2-kinesis/src/test/java/org/apache/camel/quarkus/component/aws2/kinesis/it/Aws2KinesisTest.java
@@ -32,7 +32,6 @@ import org.eclipse.microprofile.config.Config;
 import org.eclipse.microprofile.config.ConfigProvider;
 import org.hamcrest.Matchers;
 import org.jboss.logging.Logger;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.testcontainers.containers.localstack.LocalStackContainer.Service;
 import software.amazon.awssdk.core.ResponseInputStream;
@@ -52,7 +51,6 @@ class Aws2KinesisTest {
     @Aws2Client(Service.S3)
     S3Client client;
 
-    @Disabled("https://github.com/apache/camel-quarkus/issues/3638";)
     @Test
     public void kinesis() {
         final String msg = "kinesis-" + 
java.util.UUID.randomUUID().toString().replace("-", "");