How to use forStatusCode method of org.testcontainers.containers.wait.strategy.HttpWaitStrategy class

Best Testcontainers-java code snippet using org.testcontainers.containers.wait.strategy.HttpWaitStrategy.forStatusCode

Source:WaitStrategiesTest.java

...20    public GenericContainer containerWithLogWait = new GenericContainer("redis:5.0.3").withExposedPorts(6379).waitingFor(Wait.forLogMessage(".*Ready to accept connections.*\\n", 1));21    // }22    // waitForHttpWithMultipleStatusCodes {23    // }24    private static final HttpWaitStrategy MULTI_CODE_HTTP_WAIT = Wait.forHttp("/").forStatusCode(200).forStatusCode(301);25    // waitForHttpWithStatusCodePredicate {26    // }27    private static final HttpWaitStrategy PREDICATE_HTTP_WAIT = Wait.forHttp("/all").forStatusCodeMatching(( it) -> ((it >= 200) && (it < 300)) || (it == 401));28    // waitForHttpWithTls {29    // }30    private static final HttpWaitStrategy TLS_HTTP_WAIT = Wait.forHttp("/all").usingTls();31    // healthcheckWait {32    // }33    private static final WaitStrategy HEALTHCHECK_WAIT = Wait.forHealthcheck();34    @Test35    public void testContainersAllStarted() {36        Assert.assertTrue(nginx.isRunning());37        Assert.assertTrue(nginxWithHttpWait.isRunning());38        Assert.assertTrue(containerWithLogWait.isRunning());39    }40}...

Source:ItemContainer.java

...17        addEnv("REDIS_HOST", "redis-alias");18        addEnv("REDIS_PORT", "6379");19        HttpWaitStrategy httpWaitStrategy = new HttpWaitStrategy();20        httpWaitStrategy.withStartupTimeout(Duration.ofMinutes(1));21        waitingFor(httpWaitStrategy.forPath("/actuator/health").forStatusCode(200));22        withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger(" --- item --- ")));23    }24}...

Source:AcceptorContainer.java

...12        withNetwork(network);13        withNetworkAliases("acceptor");14        HttpWaitStrategy httpWaitStrategy = new HttpWaitStrategy();15        httpWaitStrategy.withStartupTimeout(Duration.ofMinutes(2));16        waitingFor(httpWaitStrategy.forPath("/actuator/health").forStatusCode(200));17        addEnv("EUREKASERVER_PORT", "8761");18        addEnv("EUREKASERVER_URI", "http://simple-sd:8761/eureka/");19        withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger(" --- acceptor --- ")));20    }21}...

forStatusCode

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;3import org.testcontainers.utility.DockerImageName;4public class TestContainer {5    public static void main(String[] args) {6        GenericContainer container = new GenericContainer(DockerImageName.parse("testcontainers/ryuk:0.3.1"))7                .withExposedPorts(8080)8                .waitingFor(new HttpWaitStrategy().forStatusCode(200));9        container.start();10    }11}12	at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:88)13	at org.testcontainers.containers.wait.strategy.HttpWaitStrategy.waitUntilReady(HttpWaitStrategy.java:106)14	at org.testcontainers.containers.wait.strategy.AbstractWaitStrategy.waitUntilReady(AbstractWaitStrategy.java:35)15	at org.testcontainers.containers.GenericContainer.waitUntilContainerStarted(GenericContainer.java:1015)16	at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:490)17	at org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:317)18	at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:81)19	at org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:315)20	at org.testcontainers.containers.GenericContainer.start(GenericContainer.java:303)21	at TestContainer.main(TestContainer.java:12)22	at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:494)23	at org.testcontainers.containers.wait.strategy.HttpWaitStrategy.waitUntilReady(HttpWaitStrategy.java:108)24	at org.testcontainers.containers.wait.strategy.AbstractWaitStrategy.waitUntilReady(AbstractWaitStrategy.java:35)25	at org.testcontainers.containers.GenericContainer.waitUntilContainerStarted(GenericContainer.java:1015)26	at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:490)

forStatusCode

Using AI Code Generation

1package org.testcontainers.containers.wait.strategy;2import org.jetbrains.annotations.NotNull;3import org.testcontainers.containers.ContainerLaunchException;4import org.testcontainers.containers.GenericContainer;5import org.testcontainers.containers.wait.strategy.WaitStrategyTarget;6import org.testcontainers.containers.wait.strategy.WaitStrategyTarget;7import org.testcontainers.utility.ResourceReaper;8import java.io.IOException;9import java.util.concurrent.TimeUnit;10import java.util.concurrent.TimeoutException;11public class HttpWaitStrategy extends AbstractWaitStrategy {12    private final String path;13    private int expectedStatusCode = 200;14    public HttpWaitStrategy(String path) {15        this.path = path;16    }17    public HttpWaitStrategy(String path, int expectedStatusCode) {18        this.path = path;19        this.expectedStatusCode = expectedStatusCode;20    }21    protected void waitUntilReady() {22        WaitStrategyTarget waitStrategyTarget = waitStrategyTarget();23        waitStrategyTarget.waitUntilContainerStarted();24        waitStrategyTarget.waitUntilPortsAreBound(1);25        String host = waitStrategyTarget.getContainerIpAddress();26        int port = waitStrategyTarget.getMappedPort(80);27        try {28            waitUntilResponse(host, port, path, expectedStatusCode);29        } catch (InterruptedException e) {30            throw new ContainerLaunchException("Timed out waiting for container to be ready", e);31        } catch (IOException e) {32            throw new ContainerLaunchException("Could not check if container is ready", e);33        }34    }35    private void waitUntilResponse(@NotNull String host, int port, @NotNull String path, int expectedStatusCode) throws IOException, InterruptedException {36        int statusCode;37        do {38            statusCode = getStatusCode(host, port, path);39            if (statusCode == expectedStatusCode) {40                return;41            }42            TimeUnit.MILLISECONDS.sleep(100);43        } while (true);44    }45    private int getStatusCode(@NotNull String host, int port, @NotNull String path) throws IOException {46        return ResourceReaper.instance().getResponseCode(host, port, path);47    }48}49package org.testcontainers.containers.wait.strategy;50import org.jetbrains.annotations.NotNull;51import

forStatusCode

Using AI Code Generation

1package org.testcontainers.containers.wait.strategy;2import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;3public class HttpWaitStrategyTest {4    public static void main(String[] args) {5        HttpWaitStrategy httpWaitStrategy = new HttpWaitStrategy();6        httpWaitStrategy.forStatusCode(200);7        System.out.println("HttpWaitStrategyTest.main");8    }9}10package org.testcontainers.containers.wait.strategy;11import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;12public class HttpWaitStrategyTest {13    public static void main(String[] args) {14        HttpWaitStrategy httpWaitStrategy = new HttpWaitStrategy();15        httpWaitStrategy.forStatusCodeMatching(response -> response == 200);16        System.out.println("HttpWaitStrategyTest.main");17    }18}19package org.testcontainers.containers.wait.strategy;20import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;21public class HttpWaitStrategyTest {22    public static void main(String[] args) {23        HttpWaitStrategy httpWaitStrategy = new HttpWaitStrategy();24        httpWaitStrategy.forPath("/status");25        System.out.println("HttpWaitStrategyTest.main");26    }27}28package org.testcontainers.containers.wait.strategy;29import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;30public class HttpWaitStrategyTest {31    public static void main(String[] args) {32        HttpWaitStrategy httpWaitStrategy = new HttpWaitStrategy();33        httpWaitStrategy.forPath("/status");34        System.out.println("HttpWaitStrategyTest.main");35    }36}37package org.testcontainers.containers.wait.strategy;38import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;39public class HttpWaitStrategyTest {40    public static void main(String[] args) {41        HttpWaitStrategy httpWaitStrategy = new HttpWaitStrategy();42        httpWaitStrategy.forPath("/status");

forStatusCode

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;3import org.testcontainers.containers.wait.strategy.Wait;4import org.testcontainers.utility.Base58;5import java.time.Duration;6public class TestContainer {7    public static void main(String[] args) {8        GenericContainer container = new GenericContainer("mysql:8.0.19")9                .withExposedPorts(3306)10                .withEnv("MYSQL_ROOT_PASSWORD", Base58.randomString(10))11                .withEnv("MYSQL_DATABASE", Base58.randomString(10))12                .waitingFor(new HttpWaitStrategy()13                        .forPort(3306)14                        .forStatusCode(200)15                        .withStartupTimeout(Duration.ofSeconds(60)));16        container.start();17    }18}19import org.testcontainers.containers.GenericContainer;20import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;21import org.testcontainers.containers.wait.strategy.Wait;22import org.testcontainers.utility.Base58;23import java.time.Duration;24public class TestContainer {25    public static void main(String[] args) {26        GenericContainer container = new GenericContainer("mysql:8.0.19")27                .withExposedPorts(3306)28                .withEnv("MYSQL_ROOT_PASSWORD", Base58.randomString(10))29                .withEnv("MYSQL_DATABASE", Base58.randomString(10))30                .waitingFor(new HttpWaitStrategy()31                        .forPort(3306)32                        .forPath("/health")33                        .withStartupTimeout(Duration.ofSeconds(60)));34        container.start();35    }36}37import org.testcontainers.containers.GenericContainer;38import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;39import org.testcontainers.containers.wait.strategy.Wait;40import org.testcontainers.utility.Base58;41import java.time.Duration;42public class TestContainer {43    public static void main(String[] args) {44        GenericContainer container = new GenericContainer("mysql:8.0.19")45                .withExposedPorts(3306)46                .withEnv("MYSQL_ROOT_PASSWORD", Base58.randomString(10))47                .withEnv("MYSQL_DATABASE", Base58.randomString(10))48                .waitingFor(new HttpWaitStrategy()

forStatusCode

Using AI Code Generation

1package org.testcontainers.containers.wait.strategy;2import com.github.dockerjava.api.command.InspectContainerResponse;3import org.rnorth.ducttape.unreliables.Unreliables;4import org.testcontainers.containers.ContainerLaunchException;5import org.testcontainers.containers.wait.strategy.AbstractWaitStrategy;6import org.testcontainers.containers.wait.strategy.WaitStrategyTarget;7import java.io.IOException;8import java.net.HttpURLConnection;9import java.net.URL;10import java.util.concurrent.TimeUnit;11import java.util.function.Predicate;12import static org.testcontainers.containers.wait.strategy.Wait.forHttp;13public class HttpWaitStrategy extends AbstractWaitStrategy {14    private String path = "/";15    private String scheme = "http";16    private int port = 80;17    private Predicate<Integer> forStatusCode = statusCode -> statusCode == 200;18    public HttpWaitStrategy() {19    }20    public HttpWaitStrategy withPath(String path) {21        this.path = path;22        return this;23    }24    public HttpWaitStrategy withScheme(String scheme) {25        this.scheme = scheme;26        return this;27    }28    public HttpWaitStrategy withPort(int port) {29        this.port = port;30        return this;31    }32    public HttpWaitStrategy forStatusCodeMatching(Predicate<Integer> statusCodePredicate) {33        this.forStatusCode = statusCodePredicate;34        return this;35    }36    public HttpWaitStrategy forStatusCode(int statusCode) {37        return this.forStatusCodeMatching(statusCode::equals);38    }39    public HttpWaitStrategy forSuccess() {40        return this.forStatusCodeMatching(statusCode -> statusCode >= 200 && statusCode < 400);41    }42    public HttpWaitStrategy forResponsePredicate(Predicate<String> responsePredicate) {43        return this.forStatusCodeMatching(statusCode -> responsePredicate.test(""));44    }45    public void waitUntilReady() {46        WaitStrategyTarget waitStrategyTarget = (WaitStrategyTarget)this.waitStrategyTarget;47        Unreliables.retryUntilSuccess(120, TimeUnit.SECONDS, () -> {48            try {49                int statusCode = this.getStatusCode(waitStrategyTarget);50                if (!this.forStatusCode.test(statusCode)) {51                    throw new IllegalStateException("Predicate not satisfied by HTTP response with status code " + statusCode);52                }53            } catch (IOException var3) {54                throw new ContainerLaunchException("Error occurred during waiting for container to be ready", var3);55            }56            return null;57        });58    }59    protected int getStatusCode(Wait

forStatusCode

Using AI Code Generation

1public class 1 {2    public static void main(String[] args) {3        GenericContainer container = new GenericContainer("nginx:1.13.8-alpine")4                .withExposedPorts(80)5                .waitingFor(new HttpWaitStrategy()6                        .forPort(80)7                        .forPath("/index.html")8                        .forStatusCode(200)9                        .forResponsePredicate(response -> response.contains("Welcome to nginx!")));10        container.start();11        System.out.println(container.getLogs());12    }13}

forStatusCode

Using AI Code Generation

1public class TestContainersDemo {2    public static void main(String[] args) {3        GenericContainer container = new GenericContainer("nginx:latest")4                .withExposedPorts(80)5                .waitingFor(Wait.forHttp("/").forStatusCode(200));6        container.start();7        System.out.println("Container started");8        container.stop();9    }10}11public class TestContainersDemo {12    public static void main(String[] args) {13        GenericContainer container = new GenericContainer("nginx:latest")14                .withExposedPorts(80)15                .waitingFor(Wait.forHttp("/").forPort(80));16        container.start();17        System.out.println("Container started");18        container.stop();19    }20}21public class TestContainersDemo {22    public static void main(String[] args) {23        GenericContainer container = new GenericContainer("nginx:latest")24                .withExposedPorts(80)25                .waitingFor(Wait.forHttp("/").forPath("/"));26        container.start();27        System.out.println("Container started");28        container.stop();29    }30}31public class TestContainersDemo {32    public static void main(String[] args) {33        GenericContainer container = new GenericContainer("nginx:latest")34                .withExposedPorts(80)35                .waitingFor(Wait.forHttp("/").forResponsePredicate(response -> response.contains("Welcome to nginx!")));36        container.start();37        System.out.println("Container started");38        container.stop();39    }40}41public class TestContainersDemo {42    public static void main(String[] args) {43        GenericContainer container = new GenericContainer("nginx:latest")44                .withExposedPorts(80)45                .waitingFor(Wait.forHttp("/").forStatusCodeMatching(statusCode -> statusCode == 200));46        container.start();47        System.out.println("Container started");48        container.stop();49    }50}

forStatusCode

Using AI Code Generation

1package com.testcontainers.demo;2import org.junit.jupiter.api.Test;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;5import java.time.Duration;6public class HttpWaitStrategyDemo {7    public void testHttpWaitStrategy() {8        GenericContainer container = new GenericContainer("httpd:2.4.41")9                .waitingFor(new HttpWaitStrategy()10                        .forPath("/index.html")11                        .forStatusCode(200)12                        .forResponsePredicate(response -> response.contains("It works!"))13                        .withStartupTimeout(Duration.ofSeconds(60)));14        container.start();15    }16}17package com.testcontainers.demo;18import org.junit.jupiter.api.Test;19import org.testcontainers.containers.GenericContainer;20import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;21import java.time.Duration;22public class HttpWaitStrategyDemo {23    public void testHttpWaitStrategy() {24        GenericContainer container = new GenericContainer("httpd:2.4.41")25                .waitingFor(new HttpWaitStrategy()26                        .forPath("/index.html")27                        .forStatusCodeMatching(response -> response == 200)28                        .forResponsePredicate(response -> response.contains("It works!"))29                        .withStartupTimeout(Duration.ofSeconds(60)));30        container.start();31    }32}33package com.testcontainers.demo;34import org.junit.jupiter.api.Test;35import org.testcontainers.containers.GenericContainer;36import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;37import java.time.Duration;38public class HttpWaitStrategyDemo {39    public void testHttpWaitStrategy() {40        GenericContainer container = new GenericContainer("httpd:2.4.41")41                .waitingFor(new HttpWaitStrategy()42                        .forPath("/index.html")43                        .forStatusCode(200)44                        .forResponsePredicate(response -> response.contains("It works!"))45                        .withStartupTimeout(Duration.ofSeconds(60)));46        container.start();47    }48}49        System.out.println("Container started");50        container.stop();51    }52}53public class TestContainersDemo {54    public static void main(String[] args) {55        GenericContainer container = new GenericContainer("nginx:latest")56                .withExposedPorts(80)57                .waitingFor(Wait.forHttp("/").forResponsePredicate(response -> response.contains("Welcome to nginx!")));58        container.start();59        System.out.println("Container started");60        container.stop();61    }62}63public class TestContainersDemo {64    public static void main(String[] args) {65        GenericContainer container = new GenericContainer("nginx:latest")66                .withExposedPorts(80)67                .waitingFor(Wait.forHttp("/").forStatusCodeMatching(statusCode -> statusCode == 200));68        container.start();69        System.out.println("Container started");70        container.stop();71    }72}

forStatusCode

Using AI Code Generation

1package com.testcontainers.demo;2import org.junit.jupiter.api.Test;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;5import java.time.Duration;6public class HttpWaitStrategyDemo {7    public void testHttpWaitStrategy() {8        GenericContainer container = new GenericContainer("httpd:2.4.41")9                .waitingFor(new HttpWaitStrategy()10                        .forPath("/index.html")11                        .forStatusCode(200)12                        .forResponsePredicate(response -> response.contains("It works!"))13                        .withStartupTimeout(Duration.ofSeconds(60)));14        container.start();15    }16}17package com.testcontainers.demo;18import org.junit.jupiter.api.Test;19import org.testcontainers.containers.GenericContainer;20import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;21import java.time.Duration;22public class HttpWaitStrategyDemo {23    public void testHttpWaitStrategy() {24        GenericContainer container = new GenericContainer("httpd:2.4.41")25                .waitingFor(new HttpWaitStrategy()26                        .forPath("/index.html")27                        .forStatusCodeMatching(response -> response == 200)28                        .forResponsePredicate(response -> response.contains("It works!"))29                        .withStartupTimeout(Duration.ofSeconds(60)));30        container.start();31    }32}33package com.testcontainers.demo;34import org.junit.jupiter.api.Test;35import org.testcontainers.containers.GenericContainer;36import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;37import java.time.Duration;38public class HttpWaitStrategyDemo {39    public void testHttpWaitStrategy() {40        GenericContainer container = new GenericContainer("httpd:2.4.41")41                .waitingFor(new HttpWaitStrategy()42                        .forPath("/index.html")43                        .forStatusCode(200)44                        .forResponsePredicate(response -> response.contains("It works!"))45                        .withStartupTimeout(Duration.ofSeconds(60)));46        container.start();47    }48}49        container.start();50    }51}52import org.testcontainers.containers.GenericContainer;53import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;54import org.testcontainers.containers.wait.strategy.Wait;55import org.testcontainers.utility.Base58;56import java.time.Duration;57public class TestContainer {58    public static void main(String[] args) {59        GenericContainer container = new GenericContainer("mysql:8.0.19")60                .withExposedPorts(3306)61                .withEnv("MYSQL_ROOT_PASSWORD", Base58.randomString(10))62                .withEnv("MYSQL_DATABASE", Base58.randomString(10))63                .waitingFor(new HttpWaitStrategy()64                        .forPort(3306)65                        .forPath("/health")66                        .withStartupTimeout(Duration.ofSeconds(60)));67        container.start();68    }69}70import org.testcontainers.containers.GenericContainer;71import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;72import org.testcontainers.containers.wait.strategy.Wait;73import org.testcontainers.utility.Base58;74import java.time.Duration;75public class TestContainer {76    public static void main(String[] args) {77        GenericContainer container = new GenericContainer("mysql:8.0.19")78                .withExposedPorts(3306)79                .withEnv("MYSQL_ROOT_PASSWORD", Base58.randomString(10))80                .withEnv("MYSQL_DATABASE", Base58.randomString(10))81                .waitingFor(new HttpWaitStrategy()

forStatusCode

Using AI Code Generation

1public class 1 {2    public static void main(String[] args) {3        GenericContainer container = new GenericContainer("nginx:1.13.8-alpine")4                .withExposedPorts(80)5                .waitingFor(new HttpWaitStrategy()6                        .forPort(80)7                        .forPath("/index.html")8                        .forStatusCode(200)9                        .forResponsePredicate(response -> response.contains("Welcome to nginx!")));10        container.start();11        System.out.println(container.getLogs());12    }13}

forStatusCode

Using AI Code Generation

1public class TestContainersDemo {2    public static void main(String[] args) {3        GenericContainer container = new GenericContainer("nginx:latest")4                .withExposedPorts(80)5                .waitingFor(Wait.forHttp("/").forStatusCode(200));6        container.start();7        System.out.println("Container started");8        container.stop();9    }10}11public class TestContainersDemo {12    public static void main(String[] args) {13        GenericContainer container = new GenericContainer("nginx:latest")14                .withExposedPorts(80)15                .waitingFor(Wait.forHttp("/").forPort(80));16        container.start();17        System.out.println("Container started");18        container.stop();19    }20}21public class TestContainersDemo {22    public static void main(String[] args) {23        GenericContainer container = new GenericContainer("nginx:latest")24                .withExposedPorts(80)25                .waitingFor(Wait.forHttp("/").forPath("/"));26        container.start();27        System.out.println("Container started");28        container.stop();29    }30}31public class TestContainersDemo {32    public static void main(String[] args) {33        GenericContainer container = new GenericContainer("nginx:latest")34                .withExposedPorts(80)35                .waitingFor(Wait.forHttp("/").forResponsePredicate(response -> response.contains("Welcome to nginx!")));36        container.start();37        System.out.println("Container started");38        container.stop();39    }40}41public class TestContainersDemo {42    public static void main(String[] args) {43        GenericContainer container = new GenericContainer("nginx:latest")44                .withExposedPorts(80)45                .waitingFor(Wait.forHttp("/").forStatusCodeMatching(statusCode -> statusCode == 200));46        container.start();47        System.out.println("Container started");48        container.stop();49    }50}

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.