Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

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

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

Source:OpensearchContainer.java

...83                    .allowInsecure()84                    .forPort(DEFAULT_HTTP_PORT)85                    .withBasicCredentials(DEFAULT_USER, DEFAULT_PASSWORD)86                    .forStatusCodeMatching(response -> response == HTTP_OK || response == HTTP_UNAUTHORIZED)87                    .withReadTimeout(Duration.ofSeconds(10))88                    .withStartupTimeout(Duration.ofMinutes(5));89        } else {90            waitStrategy = new HttpWaitStrategy()91                    .forPort(DEFAULT_HTTP_PORT)92                    .forStatusCodeMatching(response -> response == HTTP_OK)93                    .withReadTimeout(Duration.ofSeconds(10))94                    .withStartupTimeout(Duration.ofMinutes(5));95        }96        setWaitStrategy(waitStrategy);97    }98    /**99     * Return HTTP(s) host and port to connect to Opensearch container.100     *101     * @return HTTP(s) host and port (in a form of "host:port")102     */103    public String getHttpHostAddress() {104        return (disableSecurity ? "http://" : "https://") + getHost() + ":" + getMappedPort(DEFAULT_HTTP_PORT);105    }106    /**107     * Check if security plugin was enabled or not for this container...

Source:ZeebeBrokerContainer.java

...99    return new HttpWaitStrategy()100        .forPath("/ready")101        .forPort(ZeebePort.MONITORING.getPort())102        .forStatusCode(204)103        .withReadTimeout(Duration.ofSeconds(10));104  }105}...

Source:WaitingForStrategies.java

...26                .forPort(port)27                .withMethod("GET")28                .forPath("/actuator/health")29                .forStatusCode(200)30                .withReadTimeout(Duration.ofSeconds(3))31                .withStartupTimeout(Duration.ofMinutes(3));32    }33    34    public static WaitStrategy newGatewayStrategy(int port) {35        return new HttpWaitStrategy()36                .allowInsecure()37                .forPort(port)38                .withMethod("GET")39                .forPath("/actuator/health")40                .forStatusCode(200)41                .withReadTimeout(Duration.ofSeconds(3))42                .withStartupTimeout(Duration.ofMinutes(3));43    }44    45}...

withReadTimeout

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;3import org.testcontainers.containers.wait.strategy.WaitStrategy;4public class Main {5    public static void main(String[] args) {6        GenericContainer container = new GenericContainer("nginx:latest");7        container.start();8        WaitStrategy waitStrategy = new HttpWaitStrategy().forPath("/").withReadTimeout(10000);9        waitStrategy.waitUntilReady(container);10        System.out.println("Container is ready");11    }12}

withReadTimeout

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;3public class HttpWaitStrategyTest {4    public static void main(String[] args) {5        GenericContainer container = new GenericContainer("tomcat:8.5.23-jre8")6                .withExposedPorts(8080)7                .waitingFor(new HttpWaitStrategy()8                        .forPath("/manager/html")9                        .forPort(8080)10                        .withStartupTimeout(new Duration(60, SECONDS))11                        .withReadTimeout(new Duration(60, SECONDS)));12        container.start();13    }14}15	at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:83)16	at org.testcontainers.containers.wait.HttpWaitStrategy.waitUntilReady(HttpWaitStrategy.java:162)17	at org.testcontainers.containers.wait.HttpWaitStrategy.waitUntilReady(HttpWaitStrategy.java:31)18	at org.testcontainers.containers.wait.strategy.AbstractWaitStrategy.waitUntilReady(AbstractWaitStrategy.java:28)19	at org.testcontainers.containers.GenericContainer.waitUntilContainerStarted(GenericContainer.java:524)20	at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:239)21	at org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:208)22	at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:76)23	at org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:206)24	at org.testcontainers.containers.GenericContainer.start(GenericContainer.java:192)25	at HttpWaitStrategyTest.main(HttpWaitStrategyTest.java:10)26	at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:244)27	at org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:208)28	at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:76)29	at org.testcontainers.containers.wait.HttpWaitStrategy.waitUntilReady(HttpWaitStrategy.java

withReadTimeout

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;3public class HttpWaitStrategyExample {4    public static void main(String[] args) {5        GenericContainer container = new GenericContainer("httpd:2.4-alpine")6                .withExposedPorts(80)7                .waitingFor(new HttpWaitStrategy()8                        .forPath("/")9                        .forPort(80)10                        .forStatusCode(200)11                        .withReadTimeout(1000)12                );13        container.start();14        System.out.println("Container is ready");15    }16}

withReadTimeout

Using AI Code Generation

1import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;2import org.testcontainers.containers.wait.strategy.WaitStrategy;3import org.testcontainers.utility.Base58;4import java.time.Duration;5public class HttpWaitStrategyWithReadTimeout extends HttpWaitStrategy {6    private Duration readTimeout = Duration.ofSeconds(30);7    public HttpWaitStrategyWithReadTimeout() {8        super();9    }10    public HttpWaitStrategyWithReadTimeout(String path) {11        super(path);12    }13    public HttpWaitStrategyWithReadTimeout withReadTimeout(Duration readTimeout) {14        this.readTimeout = readTimeout;15        return this;16    }17    protected void waitUntilReady() {18        String containerIpAddress = waitStrategyTarget.getContainerIpAddress();19        int mappedPort = waitStrategyTarget.getMappedPort(port);20        String path = waitStrategyTarget.getPath();21        String responseBody = waitStrategyTarget.getReadinessCheckUrl(path)22                .withReadTimeout(readTimeout)23                .get(String.class);24        log.debug("Response body: {}", responseBody);25    }26    public String toString() {27        return String.format("HTTP wait strategy: %s:%d%s (read timeout %d seconds)", waitStrategyTarget.getContainerIpAddress(), port, waitStrategyTarget.getPath(), readTimeout.getSeconds());28    }29}30import org.testcontainers.containers.GenericContainer;31import org.testcontainers.containers.wait.strategy.WaitStrategy;32import org.testcontainers.utility.Base58;33import java.util.concurrent.TimeUnit;34public class CustomGenericContainer<T extends CustomGenericContainer<T>> extends GenericContainer<T> {35    public CustomGenericContainer(String dockerImageName) {36        super(dockerImageName);37    }38    protected void configure() {39        super.configure();40        WaitStrategy waitStrategy = new HttpWaitStrategyWithReadTimeout("/health")41                .forPort(8080)42                .withStartupTimeout(Duration.ofSeconds(60))43                .withReadTimeout(Duration.ofSeconds(60));44        waitingFor(waitStrategy);45    }46}47public class Test {48    public static void main(String

withReadTimeout

Using AI Code Generation

1public class HttpWaitStrategyExample {2  public static void main(String[] args) throws IOException, InterruptedException {3    GenericContainer container = new GenericContainer("nginx:1.13.12-alpine")4      .withExposedPorts(80)5      .waitingFor(6        new HttpWaitStrategy()7          .forPath("/health")8          .forPort(80)9          .forStatusCode(200)10          .withStartupTimeout(Duration.ofSeconds(30))11          .withReadTimeout(Duration.ofSeconds(5))12      );13    container.start();14  }15}16public class HttpWaitStrategyExample {17  public static void main(String[] args) throws IOException, InterruptedException {18    GenericContainer container = new GenericContainer("nginx:1.13.12-alpine")19      .withExposedPorts(80)20      .waitingFor(21        new HttpWaitStrategy()22          .forPath("/health")23          .forPort(80)24          .forStatusCode(200)25          .withStartupTimeout(Duration.ofSeconds(30))26          .withReadTimeout(Duration.ofSeconds(5))27      );28    container.start();29  }30}31public class HttpWaitStrategyExample {32  public static void main(String[] args) throws IOException, InterruptedException {33    GenericContainer container = new GenericContainer("nginx:1.13.12-alpine")34      .withExposedPorts(80)35      .waitingFor(36        new HttpWaitStrategy()37          .forPath("/health")38          .forPort(80)39          .forStatusCode(200)40          .withStartupTimeout(Duration.ofSeconds(30))41          .withReadTimeout(Duration.ofSeconds(5))42      );43    container.start();44  }45}46public class HttpWaitStrategyExample {47  public static void main(String[] args) throws IOException, InterruptedException {48    GenericContainer container = new GenericContainer("nginx:1.13.12-alpine")49      .withExposedPorts(80)50      .waitingFor(51        new HttpWaitStrategy()52          .forPath("/health")53          .forPort(80)54          .forStatusCode(200)

withReadTimeout

Using AI Code Generation

1import org.testcontainers.containers.wait.strategy.HttpWaitStrategy;2import org.testcontainers.containers.wait.strategy.WaitStrategy;3import java.time.Duration;4import java.util.concurrent.TimeUnit;5public class HttpWaitStrategyReadTimeout {6    public static void main(String[] args) {7        WaitStrategy waitStrategy = new HttpWaitStrategy()8                .forPath("/healthcheck")9                .forPort(8080)10                .withStartupTimeout(Duration.ofSeconds(60))11                .withReadTimeout(30, TimeUnit.SECONDS);12    }13}

withReadTimeout

Using AI Code Generation

1package org.testcontainers.containers.wait.strategy;2import org.apache.http.client.config.RequestConfig;3import org.apache.http.client.methods.HttpGet;4import org.apache.http.client.methods.HttpUriRequest;5import org.apache.http.impl.client.CloseableHttpClient;6import org.apache.http.impl.client.HttpClients;7import org.jetbrains.annotations.NotNull;8import org.rnorth.ducttape.timeouts.Timeouts;9import org.rnorth.ducttape.unreliables.Unreliables;10import org.testcontainers.containers.ContainerLaunchException;11import org.testcontainers.containers.GenericContainer;12import org.testcontainers.containers.wait.strategy.internal.HttpWaitStrategyTarget;13import org.testcontainers.containers.wait.strategy.internal.WaitStrategyTarget;14import java.io.IOException;15import java.net.URI;16import java.util.concurrent.TimeUnit;17import java.util.function.Predicate;18public class HttpWaitStrategy extends AbstractWaitStrategy {19    private final String path;20    private final int expectedStatusCode;21    private final Predicate<String> responsePredicate;22    private int readTimeout = 500;23    public HttpWaitStrategy() {24        this("/");25    }26    public HttpWaitStrategy(String path) {27        this(path, 200);28    }29    public HttpWaitStrategy(String path, int expectedStatusCode) {30        this(path, expectedStatusCode, s -> true);31    }32    public HttpWaitStrategy(String path, int expectedStatusCode, Predicate<String> responsePredicate) {33        this.path = path;34        this.expectedStatusCode = expectedStatusCode;35        this.responsePredicate = responsePredicate;36    }37    protected void waitUntilReady() {38        WaitStrategyTarget waitStrategyTarget = new HttpWaitStrategyTarget(container);39        Unreliables.retryUntilSuccess((int) startupTimeout.getSeconds(), TimeUnit.SECONDS, () -> {40            try {41                final HttpUriRequest request = createRequest(waitStrategyTarget);42                final int statusCode = waitStrategyTarget.getHttpClient().execute(request, waitStrategyTarget.getHttpResponseHandler());43                if (statusCode != expectedStatusCode) {44                    throw new IllegalStateException("Received status code " + statusCode + " from " + request.getURI());45                }46                return null;47            } catch (IOException e) {48                throw new ContainerLaunchException("Error waiting for container to be ready", e);49            }50        });51    }52    protected HttpUriRequest createRequest(WaitStrategyTarget waitStrategyTarget) {53        URI uri = waitStrategyTarget.getUri(path);

withReadTimeout

Using AI Code Generation

1public class HttpWaitStrategy extends WaitStrategyTarget {2    private final String path;3    private final int expectedStatusCode;4    private final int readTimeout;5    public HttpWaitStrategy(int expectedStatusCode, String path) {6        this(expectedStatusCode, path, 10);7    }8    public HttpWaitStrategy(int expectedStatusCode, String path, int readTimeout) {9        this.path = path;10        this.expectedStatusCode = expectedStatusCode;11        this.readTimeout = readTimeout;12    }13    protected void waitUntilReady() {14        try {15            log.debug("Waiting for {} seconds for URL: {} to be accessible (host port mapping not yet available)", startupTimeout.getSeconds(), getEndpointDescription());16            Unreliables.retryUntilSuccess((int) startupTimeout.getSeconds(), TimeUnit.SECONDS, () -> {17                try {18                    final URL url = new URL(getEndpoint());19                    HttpURLConnection connection = (HttpURLConnection) url.openConnection();20                    connection.setRequestMethod("GET");21                    connection.setConnectTimeout(1000);22                    connection.setReadTimeout(readTimeout * 1000);23                    connection.connect();24                    int responseCode = connection.getResponseCode();25                    if (responseCode == expectedStatusCode) {26                        log.debug("Received response code {} from URL: {}", responseCode, getEndpointDescription());27                        return true;28                    } else {29                        log.debug("Received response code {} from URL: {} (expected: {})", responseCode, getEndpointDescription(), expectedStatusCode);30                        return false;31                    }32                } catch (IOException e) {33                    log.debug("Could not connect to URL: {}", getEndpointDescription(), e);34                    return false;35                }36            });37        } catch (TimeoutException e) {38            throw new ContainerLaunchException("Timed out waiting for URL to be accessible (host port mapping not yet available): " + getEndpointDescription());39        }40    }41    protected String getLivenessCheckDescription() {42        return String.format("URL (%s) must return HTTP %d", getEndpointDescription(), expectedStatusCode);43    }44    private String getEndpoint() {45    }46    private String getEndpointDescription() {47    }48}

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.