[camel-quarkus] branch master updated: Add some logging to debug #1632

[ja...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 29b2694  Add some logging to debug #1632
29b2694 is described below

commit 29b26944d87e6c35b4d09d7ec6daa3634d307847
Author: James Netherton <ja...@gmail.com>
AuthorDate: Tue Sep 1 15:24:22 2020 +0100

    Add some logging to debug #1632
---
 .../component/smallrye/reactive/messaging/it/PublisherRoute.java    | 6 ++++++
 .../reactive/messaging/it/SmallRyeReactiveMessagingTest.java        | 4 ++++
 2 files changed, 10 insertions(+)

diff --git a/integration-tests/smallrye-reactive-messaging/src/main/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/it/PublisherRoute.java b/integration-tests/smallrye-reactive-messaging/src/main/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/it/PublisherRoute.java
index b32edae..becbf9b 100644
--- a/integration-tests/smallrye-reactive-messaging/src/main/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/it/PublisherRoute.java
+++ b/integration-tests/smallrye-reactive-messaging/src/main/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/it/PublisherRoute.java
@@ -26,10 +26,13 @@ import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 import org.eclipse.microprofile.reactive.messaging.Outgoing;
+import org.jboss.logging.Logger;
 import org.reactivestreams.Publisher;
 
 public class PublisherRoute extends RouteBuilder {
 
+    private static final Logger LOG = Logger.getLogger(PublisherRoute.class);
+
     @Inject
     CamelReactiveStreamsService camel;
 
@@ -38,7 +41,10 @@ public class PublisherRoute extends RouteBuilder {
 
     @Incoming("sink")
     public CompletionStage<Void> sink(String value) {
+        LOG.infof("Results before add: %s", String.join(",", results.getResults()));
+        LOG.infof("Adding result value: %s", value);
         results.addResult(value);
+        LOG.infof("Results after add: %s", String.join(",", results.getResults()));
         return CompletableFuture.completedFuture(null);
     }
 
diff --git a/integration-tests/smallrye-reactive-messaging/src/test/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/it/SmallRyeReactiveMessagingTest.java b/integration-tests/smallrye-reactive-messaging/src/test/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/it/SmallRyeReactiveMessagingTest.java
index 005910e..d75d79a 100644
--- a/integration-tests/smallrye-reactive-messaging/src/test/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/it/SmallRyeReactiveMessagingTest.java
+++ b/integration-tests/smallrye-reactive-messaging/src/test/java/org/apache/camel/quarkus/component/smallrye/reactive/messaging/it/SmallRyeReactiveMessagingTest.java
@@ -25,6 +25,7 @@ import java.util.stream.Stream;
 
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.RestAssured;
+import org.jboss.logging.Logger;
 import org.junit.jupiter.api.Test;
 
 import static org.awaitility.Awaitility.await;
@@ -32,6 +33,8 @@ import static org.awaitility.Awaitility.await;
 @QuarkusTest
 class SmallRyeReactiveMessagingTest {
 
+    private static final Logger LOG = Logger.getLogger(SmallRyeReactiveMessagingTest.class);
+
     @Test
     public void testSmallRyeReactiveMessagingCamelRouteSubscriber() {
         Path path = Paths.get("target/values.txt");
@@ -66,6 +69,7 @@ class SmallRyeReactiveMessagingTest {
                     .extract()
                     .body()
                     .asString();
+            LOG.infof("Values: %s", response);
             return response.equals("A,B,C,D");
         });
     }