How to use Object method of org.testcontainers.containers.DockerComposeContainer class

Best Testcontainers-java code snippet using org.testcontainers.containers.DockerComposeContainer.Object

Source:HyperIoTTestContainerUtil.java

...55                //if port mappings have been defined56                if (portList != null) {57                    Integer[] ports = new Integer[portList.size()];58                    portList.toArray(ports);59                    logger.info("Waiting for container {} with port {}", new Object[]{containerName, ports});60                    GenericContainer container = new GenericContainer(DockerImageName.parse(imagesList.get(containerName)))61                            .withExposedPorts(ports)62                            .withStartupTimeout(Duration.ofMillis(defaultStartupTimeputMs))63                            .withReuse(true);64                    container.waitingFor(Wait.forListeningPort());65                    containersMap.put(containerName, container);66                    awaitForContainerStart(container);67                }68            } catch (Throwable t) {69                logger.error(t.getMessage(), t);70            }71        }72        return containersMap;73    }74    private static void awaitForContainerStart(GenericContainer container) {75        Awaitility.await()76                .atMost(5, TimeUnit.SECONDS)77                .pollInterval(DynamicPollInterval.ofMillis(50))78                .pollInSameThread()79                .until(80                        () -> container.getContainerInfo(),81                        inspectContainerResponse -> {82                            Set<Integer> exposedAndMappedPorts = inspectContainerResponse83                                    .getNetworkSettings()84                                    .getPorts()85                                    .getBindings()86                                    .entrySet()87                                    .stream()88                                    .filter(it -> Objects.nonNull(it.getValue())) // filter out exposed but not yet mapped89                                    .map(Map.Entry::getKey)90                                    .map(ExposedPort::getPort)91                                    .collect(Collectors.toSet());92                            return exposedAndMappedPorts.containsAll(container.getExposedPorts());93                        });94    }95}...

Source:DockerComposeWaitStrategyTest.java

...11    @Test12    public void testWaitOnListeningPort() {13        final DockerComposeContainer environment = new DockerComposeContainer(new File("src/test/resources/compose-test.yml")).withExposedService("redis_1", DockerComposeWaitStrategyTest.REDIS_PORT, Wait.forListeningPort());14        try {15            environment.starting(Description.createTestDescription(Object.class, "name"));16            VisibleAssertions.pass("Docker compose should start after waiting for listening port");17        } catch (RuntimeException e) {18            VisibleAssertions.fail(("Docker compose should start after waiting for listening port with failed with: " + e));19        }20    }21    @Test22    public void testWaitOnMultipleStrategiesPassing() {23        final DockerComposeContainer environment = new DockerComposeContainer(new File("src/test/resources/compose-test.yml")).withExposedService("redis_1", DockerComposeWaitStrategyTest.REDIS_PORT, Wait.forListeningPort()).withExposedService("db_1", 3306, Wait.forLogMessage(".*ready for connections.*\\s", 1)).withTailChildContainers(true);24        try {25            environment.starting(Description.createTestDescription(Object.class, "name"));26            VisibleAssertions.pass("Docker compose should start after waiting for listening port");27        } catch (RuntimeException e) {28            VisibleAssertions.fail(("Docker compose should start after waiting for listening port with failed with: " + e));29        }30    }31    @Test32    public void testWaitingFails() {33        final DockerComposeContainer environment = new DockerComposeContainer(new File("src/test/resources/compose-test.yml")).withExposedService("redis_1", DockerComposeWaitStrategyTest.REDIS_PORT, Wait.forHttp("/test").withStartupTimeout(Duration.ofSeconds(10)));34        VisibleAssertions.assertThrows("waiting on an invalid http path times out", RuntimeException.class, () -> environment.starting(Description.createTestDescription(.class, "name")));35    }36    @Test37    public void testWaitOnOneOfMultipleStrategiesFailing() {38        final DockerComposeContainer environment = new DockerComposeContainer(new File("src/test/resources/compose-test.yml")).withExposedService("redis_1", DockerComposeWaitStrategyTest.REDIS_PORT, Wait.forListeningPort().withStartupTimeout(Duration.ofSeconds(10))).waitingFor("db_1", Wait.forLogMessage(".*test test test.*\\s", 1).withStartupTimeout(Duration.ofSeconds(10))).withTailChildContainers(true);39        VisibleAssertions.assertThrows("waiting on one failing strategy to time out", RuntimeException.class, () -> environment.starting(Description.createTestDescription(.class, "name")));...

Source:ApplicationTest.java

1package com.github.ivpal.prefx;2import io.restassured.builder.RequestSpecBuilder;3import io.restassured.filter.log.RequestLoggingFilter;4import io.restassured.filter.log.ResponseLoggingFilter;5import io.vertx.core.json.JsonObject;6import org.junit.jupiter.api.Test;7import org.testcontainers.containers.DockerComposeContainer;8import org.testcontainers.containers.wait.strategy.Wait;9import org.testcontainers.junit.jupiter.Container;10import org.testcontainers.junit.jupiter.Testcontainers;11import java.io.File;12import static io.restassured.RestAssured.given;13import static java.util.Arrays.asList;14import static org.hamcrest.MatcherAssert.assertThat;15import static org.hamcrest.Matchers.arrayWithSize;16import static org.hamcrest.Matchers.hasItemInArray;17import static org.hamcrest.Matchers.hasSize;18@Testcontainers19public class ApplicationTest {20    @Container21    private static final DockerComposeContainer<?> containers = new DockerComposeContainer<>(new File("docker-compose.test.yml"))22        .withExposedService("app", 8000)23        .waitingFor("app", Wait.defaultWaitStrategy());24    @Test25    public void completionsTest() {26        var spec = new RequestSpecBuilder()27            .addFilters(asList(new ResponseLoggingFilter(), new RequestLoggingFilter()))28            .setBaseUri("http://localhost:8000/")29            .build();30        given()31            .spec(spec)32            .get("/completions?prefix=Tw")33            .then()34            .assertThat()35            .statusCode(200)36            .body("$", hasSize(0));37        given()38            .spec(spec)39            .header("Content-Type", "application/json")40            .body(new JsonObject().put("query", "Twitter").put("completion", "Twitter").encode())41            .post("/completions")42            .then()43            .assertThat()44            .statusCode(200);45        var completions = given()46            .spec(spec)47            .get("/completions?prefix=Tw")48            .then()49            .assertThat()50            .statusCode(200)51            .extract()52            .as(String[].class);53        assertThat(completions, arrayWithSize(1));54        assertThat(completions, hasItemInArray("Twitter"));...

Object

Using AI Code Generation

1import org.testcontainers.containers.DockerComposeContainer;2public class Test {3    public static void main(String[] args) {4        DockerComposeContainer container = new DockerComposeContainer(new File("docker-compose.yml"));5        container.start();6    }7}8import org.testcontainers.containers.DockerComposeContainer;9public class Test {10    public static void main(String[] args) {11        DockerComposeContainer container = new DockerComposeContainer(new File("docker-compose.yml"));12        container.start();13    }14}15import org.testcontainers.containers.DockerComposeContainer;16public class Test {17    public static void main(String[] args) {18        DockerComposeContainer container = new DockerComposeContainer(new File("docker-compose.yml"));19        container.start();20    }21}22import org.testcontainers.containers.DockerComposeContainer;23public class Test {24    public static void main(String[] args) {25        DockerComposeContainer container = new DockerComposeContainer(new File("docker-compose.yml"));26        container.start();27    }28}29import org.testcontainers.containers.DockerComposeContainer;30public class Test {31    public static void main(String[] args) {32        DockerComposeContainer container = new DockerComposeContainer(new File("docker-compose.yml"));33        container.start();34    }35}36import org.testcontainers.containers.DockerComposeContainer;37public class Test {38    public static void main(String[] args) {39        DockerComposeContainer container = new DockerComposeContainer(new File("docker-compose.yml"));40        container.start();41    }42}43import org.testcontainers.containers.DockerComposeContainer;44public class Test {45    public static void main(String[] args) {46        DockerComposeContainer container = new DockerComposeContainer(new File("docker-compose.yml"));47        container.start();48    }49}

Object

Using AI Code Generation

1package org.testcontainers.containers;2import java.io.File;3import java.io.IOException;4import java.nio.file.Files;5import java.nio.file.Path;6import java.nio.file.Paths;7import java.util.Map;8import org.junit.Test;9import org.testcontainers.DockerClientFactory;10import org.testcontainers.containers.wait.strategy.Wait;11public class ObjectTest {12    public void testObject() throws IOException {13        Path composeFile = Files.createTempFile("docker-compose", ".yml");14        Path file = Paths.get("src/test/resources/docker-compose.yml");15        Files.copy(file, composeFile);16        DockerComposeContainer container = new DockerComposeContainer(new File(composeFile.toUri()))17                .withExposedService("redis_1", 6379, Wait.forListeningPort())18                .withExposedService("redis_2", 6379, Wait.forListeningPort())19                .withExposedService("redis_3", 6379, Wait.forListeningPort());20        container.start();21        Map<String, Container> containerMap = container.getContainerMap();22        Container redis1 = containerMap.get("redis_1");23        Container redis2 = containerMap.get("redis_2");24        Container redis3 = containerMap.get("redis_3");25        System.out.println("redis_1: " + redis1.getContainerIpAddress());26        System.out.println("redis_2: " + redis2.getContainerIpAddress());27        System.out.println("redis_3: " + redis3.getContainerIpAddress());28        container.stop();29    }30}31package org.testcontainers.containers;32import java.io.File;33import java.io.IOException;34import java.nio.file.Files;35import java.nio.file.Path;36import java.nio.file.Paths;37import java.util.Map;38import org.junit.Test;39import org.testcontainers.DockerClientFactory;40import org.testcontainers.containers.wait.strategy.Wait;41public class ObjectTest {42    public void testObject() throws IOException {43        Path composeFile = Files.createTempFile("docker-compose", ".yml");44        Path file = Paths.get("src/test/resources/docker-compose.yml");45        Files.copy(file, composeFile);46        DockerComposeContainer container = new DockerComposeContainer(new File(composeFile.toUri()))47                .withExposedService("redis_1", 6379, Wait.forListeningPort())

Object

Using AI Code Generation

1package org.testcontainers.containers;2import java.io.File;3import java.io.IOException;4import java.util.List;5import java.util.Map;6import java.util.concurrent.TimeUnit;7import org.testcontainers.containers.output.OutputFrame;8import org.testcontainers.containers.output.ToStringConsumer;9import org.testcontainers.containers.wait.strategy.Wait;10import org.testcontainers.containers.wait.strategy.WaitAllStrategy;11import org.testcontainers.containers.wait.strategy.WaitStrategy;12import org.testcontainers.images.builder.ImageFromDockerfile;13import org.testcontainers.utility.Base58;14import org.testcontainers.utility.MountableFile;15GenericContainer<SELF> {16private static final int DEFAULT_EXTERNAL_PORT = 80;17private final Map<String, String> env;18private final File composeFile;19private final String[] envFiles;20private final String identifier;21private final List<String> commandParts;22private final List<WaitStrategy> waitStrategy;23private final List<ExposedService> exposedServices;24private final Map<String, String> serviceNames;25private final Map<String, Integer> scalingProperties;26private final Map<String, String> links;27private final Map<String, String> volumes;28private final Map<String, String> volumesFrom;29private final Map<String, String> extraHosts;30private final Map<String, String> labels;31private final Map<String, String> logging;32private final Map<String, String> networkMode;33private final Map<String, String> networkAliases;34private final Map<String, Map<String, String>> portBindings;35private final Map<String, String[]> entrypoint;36private final Map<String, String> workingDir;37private final Map<String, List<String>> command;38private final Map<String, String> user;39private final Map<String, String> hostname;40private final Map<String, Map<String, String>> tmpfs;41private final Map<String, List<String>> dependsOn;42private final Map<String, Map<String, String>> build;43private final Map<String, Map<String, String>> capAdd;44private final Map<String, Map<String, String>> capDrop;45private final Map<String, Map<String, String>> cpuShares;46private final Map<String, Map<String, String>> cpuSet;47private final Map<String, Map<String, String>> devices;48private final Map<String, Map<String, String>> dns;49private final Map<String, Map<String, String>> dnsSearch;

Object

Using AI Code Generation

1package org.testcontainers.containers;2import java.io.File;3import java.io.IOException;4import java.util.List;5import java.util.Map;6import java.util.Set;7import java.util.stream.Collectors;8import org.testcontainers.containers.output.OutputFrame;9import org.testcontainers.containers.output.ToStringConsumer;10import org.testcontainers.containers.startupcheck.OneShotStartupCheckStrategy;11import org.testcontainers.utility.MountableFile;12import com.github.dockerjava.api.DockerClient;13import com.github.dockerjava.api.command.CreateContainerCmd;14import com.github.dockerjava.api.command.ExecCreateCmdResponse;15import com.github.dockerjava.api.command.InspectContainerResponse;16import com.github.dockerjava.api.model.Bind;17import com.github.dockerjava.api.model.ContainerNetwork;18import com.github.dockerjava.api.model.ExposedPort;19import com.github.dockerjava.api.model.Frame;20import com.github.dockerjava.api.model.InternetProtocol;21import com.github.dockerjava.api.model.PortBinding;22import com.github.dockerjava.api.model.Ports.Binding;23import com.github.dockerjava.core.command.ExecStartResultCallback;24import lombok.Getter;25import lombok.NonNull;26import lombok.SneakyThrows;27import lombok.extern.slf4j.Slf4j;

Object

Using AI Code Generation

1package org.testcontainers.containers;2import org.junit.Test;3import java.io.File;4public class DockerComposeContainerTest {5    public void testDockerComposeContainer() {6        File composeFile = new File("docker-compose.yml");7        DockerComposeContainer container = new DockerComposeContainer(composeFile);8        container.withExposedService("redis_1", 6379);9        container.start();10    }11}12package org.testcontainers.containers;13import org.junit.Test;14import java.io.File;15public class DockerComposeContainerTest {16    public void testDockerComposeContainer() {17        File composeFile = new File("docker-compose.yml");18        DockerComposeContainer container = new DockerComposeContainer(composeFile);19        container.withExposedService("redis_1", 6379);20        container.start();21    }22}

Object

Using AI Code Generation

1import org.testcontainers.containers.DockerComposeContainer;2import org.testcontainers.containers.wait.strategy.Wait;3import java.io.File;4import org.testcontainers.containers.output.OutputFrame;5import org.testcontainers.containers.output.Slf4jLogConsumer;6import org.slf4j.Logger;7import org.slf4j.LoggerFactory;8import java.util.concurrent.TimeUnit;9import java.util.concurrent.TimeoutException;10public class 1 {11    public static void main(String[] args) throws InterruptedException, TimeoutException {12        File composeFile = new File("/home/1/docker-compose.yml");13        DockerComposeContainer container = new DockerComposeContainer(composeFile)14                .withExposedService("1", 8080, Wait.forListeningPort())15                .withExposedService("1", 8081, Wait.forListeningPort())16                .withExposedService("1", 8082, Wait.forListeningPort())17                .withExposedService("1", 8083, Wait.forListeningPort())18                .withExposedService("1", 8084, Wait.forListeningPort())19                .withExposedService("1", 8085, Wait.forListeningPort())20                .withExposedService("1", 8086, Wait.forListeningPort())21                .withExposedService("1", 8087, Wait.forListeningPort())22                .withExposedService("1", 8088, Wait.forListeningPort())23                .withExposedService("1", 8089, Wait.forListeningPort())24                .withExposedService("1", 8090, Wait.forListeningPort())25                .withExposedService("1", 8091, Wait.forListeningPort())26                .withExposedService("1", 8092, Wait.forListeningPort())27                .withExposedService("1", 8093, Wait.forListeningPort())28                .withExposedService("1", 8094, Wait.forListeningPort())29                .withExposedService("1", 8095, Wait.forListeningPort())30                .withExposedService("1", 8096, Wait.forListeningPort())31                .withExposedService("1", 8097, Wait.forListeningPort())32                .withExposedService("1", 8098, Wait.forListeningPort())33                .withExposedService("1", 8099, Wait.forListeningPort())34                .withExposedService("1", 8100, Wait.forListeningPort())35                .withExposedService("1", 810

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.