[camel-quarkus] branch main updated: Log warning instead of throw exception for Debezium MongoDB container script execution failure

[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 141c3b3f36 Log warning instead of throw exception for Debezium MongoDB 
container script execution failure
141c3b3f36 is described below

commit 141c3b3f369608c7d514dba8d3db4a5970a152f3
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Thu Aug 25 07:24:58 2022 +0100

    Log warning instead of throw exception for Debezium MongoDB container 
script execution failure
---
 .../debezium/common/it/mongodb/DebeziumMongodbTestResource.java     | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/mongodb/DebeziumMongodbTestResource.java
 
b/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/mongodb/DebeziumMongodbTestResource.java
index b48d897b90..cc75f3512a 100644
--- 
a/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/mongodb/DebeziumMongodbTestResource.java
+++ 
b/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/mongodb/DebeziumMongodbTestResource.java
@@ -22,12 +22,14 @@ import java.nio.charset.StandardCharsets;
 import 
org.apache.camel.quarkus.component.debezium.common.it.AbstractDebeziumTestResource;
 import org.apache.camel.quarkus.component.debezium.common.it.Type;
 import org.apache.commons.io.IOUtils;
+import org.jboss.logging.Logger;
 import org.testcontainers.containers.Container;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.Network;
 import org.testcontainers.containers.wait.strategy.Wait;
 
 public class DebeziumMongodbTestResource extends 
AbstractDebeziumTestResource<GenericContainer<?>> {
+    private static final Logger LOG = 
Logger.getLogger(AbstractDebeziumTestResource.class);
     private static final String PRIVATE_HOST = "mongodb_private";
     private static final String DB_USERNAME = "debezium";
     private static final String DB_PASSWORD = "dbz";
@@ -41,7 +43,7 @@ public class DebeziumMongodbTestResource extends 
AbstractDebeziumTestResource<Ge
 
     @Override
     protected GenericContainer<?> createContainer() {
-        return new GenericContainer("mongo")
+        return new GenericContainer("mongo:4.4")
                 .withExposedPorts(DB_PORT)
                 .withCommand("--replSet", "my-mongo-set")
                 .withNetwork(net)
@@ -64,7 +66,7 @@ public class DebeziumMongodbTestResource extends 
AbstractDebeziumTestResource<Ge
         for (String cmd : cmds) {
             Container.ExecResult er = container.execInContainer("mongo", 
"--eval", cmd);
             if (er.getExitCode() != 0) {
-                throw new RuntimeException("Error executing MongoDB command: " 
+ cmd);
+                LOG.errorf("Error executing MongoDB command: %s", cmd);
             }
         }
     }