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