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

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

commit c6faa74d1d34d894e39437bb45bcbba118e9f396
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Fri Nov 17 15:28:58 2023 +0100

    (chores) camel-test-infra-etcd3: minor reliability cleanups
---
 .../test/infra/etcd3/services/Etcd3LocalContainerService.java      | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/test-infra/camel-test-infra-etcd3/src/test/java/org/apache/camel/test/infra/etcd3/services/Etcd3LocalContainerService.java
 
b/test-infra/camel-test-infra-etcd3/src/test/java/org/apache/camel/test/infra/etcd3/services/Etcd3LocalContainerService.java
index 8a650c89f94..198094b5775 100644
--- 
a/test-infra/camel-test-infra-etcd3/src/test/java/org/apache/camel/test/infra/etcd3/services/Etcd3LocalContainerService.java
+++ 
b/test-infra/camel-test-infra-etcd3/src/test/java/org/apache/camel/test/infra/etcd3/services/Etcd3LocalContainerService.java
@@ -24,6 +24,7 @@ import 
org.apache.camel.test.infra.common.services.ContainerService;
 import org.apache.camel.test.infra.etcd3.common.Etcd3Properties;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.testcontainers.containers.wait.strategy.Wait;
 
 public class Etcd3LocalContainerService implements Etcd3Service, 
ContainerService<EtcdContainer> {
     public static final String CONTAINER_IMAGE = 
"gcr.io/etcd-development/etcd:v3.5.10";
@@ -36,7 +37,7 @@ public class Etcd3LocalContainerService implements 
Etcd3Service, ContainerServic
     private final EtcdContainer container;
 
     public Etcd3LocalContainerService() {
-        this(System.getProperty("etcd.container", CONTAINER_IMAGE));
+        this(System.getProperty(Etcd3Properties.ETCD_CONTAINER, 
CONTAINER_IMAGE));
     }
 
     public Etcd3LocalContainerService(String imageName) {
@@ -51,7 +52,9 @@ public class Etcd3LocalContainerService implements 
Etcd3Service, ContainerServic
         return new EtcdContainer(imageName, CONTAINER_NAME, 
List.of(CONTAINER_NAME))
                 .withNetworkAliases(containerName)
                 .withClusterToken(UUID.randomUUID().toString())
-                .withExposedPorts(ETCD_CLIENT_PORT, ETCD_PEER_PORT);
+                .withExposedPorts(ETCD_CLIENT_PORT, ETCD_PEER_PORT)
+                .waitingFor(Wait.forListeningPort())
+                .waitingFor(Wait.forLogMessage(".*ready to serve client 
requests.*", 1));
     }
 
     @Override

Reply via email to