[camel-quarkus] branch master updated: nats: more verbose output to help with #1978

[aldettinger]

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

aldettinger 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 9401d0c  nats: more verbose output to help with #1978
9401d0c is described below

commit 9401d0ccf6d55c89b628031558a19be912e9109a
Author: aldettinger <aldettin...@gmail.com>
AuthorDate: Mon Nov 9 18:25:44 2020 +0100

    nats: more verbose output to help with #1978
---
 .../apache/camel/quarkus/component/nats/it/NatsConfiguration.java    | 4 ++++
 .../org/apache/camel/quarkus/component/nats/it/NatsTestResource.java | 5 +++++
 2 files changed, 9 insertions(+)

diff --git 
a/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsConfiguration.java
 
b/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsConfiguration.java
index b270159..1192bf8 100644
--- 
a/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsConfiguration.java
+++ 
b/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsConfiguration.java
@@ -44,6 +44,7 @@ public class NatsConfiguration {
     NatsComponent natsBasicAuth() {
         NatsComponent component = new NatsComponent();
         component.setServers(natsBasicAuthBrokerUrl);
+        component.setVerbose(true);
         return component;
     }
 
@@ -51,6 +52,7 @@ public class NatsConfiguration {
     NatsComponent natsNoAuth() {
         NatsComponent component = new NatsComponent();
         component.setServers(natsNoAuthBrokerUrl);
+        component.setVerbose(true);
         return component;
     }
 
@@ -58,6 +60,7 @@ public class NatsConfiguration {
     NatsComponent natsTlsAuth() {
         NatsComponent component = new NatsComponent();
         component.setServers(natsTlsAuthBrokerUrl);
+        component.setVerbose(true);
         return component;
     }
 
@@ -65,6 +68,7 @@ public class NatsConfiguration {
     NatsComponent natsTokenAuth() {
         NatsComponent component = new NatsComponent();
         component.setServers(natsTokenAuthBrokerUrl);
+        component.setVerbose(true);
         return component;
     }
 
diff --git 
a/integration-tests/nats/src/test/java/org/apache/camel/quarkus/component/nats/it/NatsTestResource.java
 
b/integration-tests/nats/src/test/java/org/apache/camel/quarkus/component/nats/it/NatsTestResource.java
index 1334e2e..ea1fe34 100644
--- 
a/integration-tests/nats/src/test/java/org/apache/camel/quarkus/component/nats/it/NatsTestResource.java
+++ 
b/integration-tests/nats/src/test/java/org/apache/camel/quarkus/component/nats/it/NatsTestResource.java
@@ -23,6 +23,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.BindMode;
 import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.output.Slf4jLogConsumer;
 import org.testcontainers.containers.wait.strategy.Wait;
 import org.testcontainers.utility.TestcontainersConfiguration;
 
@@ -50,6 +51,7 @@ public class NatsTestResource implements 
ContainerResourceLifecycleManager {
         // Start the container needed for the basic authentication test
         basicAuthContainer = new 
GenericContainer(NATS_IMAGE).withExposedPorts(NATS_SERVER_PORT)
                 .withCommand("-DV", "--user", BASIC_AUTH_USERNAME, "--pass", 
BASIC_AUTH_PASSWORD)
+                .withLogConsumer(new Slf4jLogConsumer(LOG))
                 .waitingFor(Wait.forLogMessage(".*Server is ready.*", 1));
         basicAuthContainer.start();
         String basicAuthIp = basicAuthContainer.getContainerIpAddress();
@@ -59,6 +61,7 @@ public class NatsTestResource implements 
ContainerResourceLifecycleManager {
 
         // Start the container needed for tests without authentication
         noAuthContainer = new 
GenericContainer(NATS_IMAGE).withExposedPorts(NATS_SERVER_PORT)
+                .withLogConsumer(new Slf4jLogConsumer(LOG))
                 .waitingFor(Wait.forLogMessage(".*Listening for route 
connections.*", 1));
         noAuthContainer.start();
         String noAuthIp = noAuthContainer.getContainerIpAddress();
@@ -73,6 +76,7 @@ public class NatsTestResource implements 
ContainerResourceLifecycleManager {
                         "--tlskey=/certs/key.pem",
                         "--tlsverify",
                         "--tlscacert=/certs/ca.pem")
+                .withLogConsumer(new Slf4jLogConsumer(LOG))
                 .waitingFor(Wait.forLogMessage(".*Server is ready.*", 1));
         tlsAuthContainer.start();
         String tlsAuthIp = tlsAuthContainer.getContainerIpAddress();
@@ -82,6 +86,7 @@ public class NatsTestResource implements 
ContainerResourceLifecycleManager {
         // Start the container needed for the token authentication test
         tokenAuthContainer = new 
GenericContainer(NATS_IMAGE).withExposedPorts(NATS_SERVER_PORT)
                 .withCommand("-DV", "-auth", TOKEN_AUTH_TOKEN)
+                .withLogConsumer(new Slf4jLogConsumer(LOG))
                 .waitingFor(Wait.forLogMessage(".*Server is ready.*", 1));
         tokenAuthContainer.start();
         String tokenAuthIp = tokenAuthContainer.getContainerIpAddress();