You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pp...@apache.org on 2022/04/18 20:58:24 UTC
[camel-quarkus] 02/11: Fix Aws2KinesisTest.kinesis test
This is an automated email from the ASF dual-hosted git repository.
ppalaga pushed a commit to branch 2.7.x
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 9beeff24efe624cc54f044ec238a3f6d93e7e429
Author: James Netherton <ja...@gmail.com>
AuthorDate: Fri Apr 8 15:16:36 2022 +0100
Fix Aws2KinesisTest.kinesis test
Fixes #3638
---
.../component/aws2/kinesis/it/Aws2KinesisResource.java | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 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() {