Join the 1-day Testing & QA Summit featuring 15+ Expert Speakers.Register for FREE! Join TestMu Conference

How to use singleListening method of org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest class

Best Testcontainers-java code snippet using org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening

Source:ExternalPortListeningCheckTest.java

...9    private ServerSocket listeningSocket2;10    private ServerSocket nonListeningSocket;11    private WaitStrategyTarget mockContainer;12    @Test13    public void singleListening() {14        final ExternalPortListeningCheck check = new ExternalPortListeningCheck(mockContainer, ImmutableSet.of(listeningSocket1.getLocalPort()));15        final Boolean result = check.call();16        VisibleAssertions.assertTrue("ExternalPortListeningCheck identifies a single listening port", result);17    }18    @Test19    public void multipleListening() {20        final ExternalPortListeningCheck check = new ExternalPortListeningCheck(mockContainer, ImmutableSet.of(listeningSocket1.getLocalPort(), listeningSocket2.getLocalPort()));21        final Boolean result = check.call();22        VisibleAssertions.assertTrue("ExternalPortListeningCheck identifies multiple listening port", result);23    }24    @Test25    public void oneNotListening() {26        final ExternalPortListeningCheck check = new ExternalPortListeningCheck(mockContainer, ImmutableSet.of(listeningSocket1.getLocalPort(), nonListeningSocket.getLocalPort()));27        assertThrows("ExternalPortListeningCheck detects a non-listening port among many", IllegalStateException.class, ((Runnable) (check::call)));...

singleListening

Using AI Code Generation

1import org.junit.jupiter.api.Test;2import org.testcontainers.containers.GenericContainer;3import org.testcontainers.containers.wait.strategy.Wait;4import org.testcontainers.junit.jupiter.Container;5import org.testcontainers.junit.jupiter.Testcontainers;6import java.io.IOException;7import java.net.Socket;8import java.net.URI;9import java.net.URISyntaxException;10import java.nio.charset.StandardCharsets;11import java.util.concurrent.TimeUnit;12import static org.hamcrest.MatcherAssert.assertThat;13import static org.hamcrest.Matchers.containsString;14import static org.rnorth.visibleassertions.VisibleAssertions.assertEquals;15import static org.rnorth.visibleassertions.VisibleAssertions.assertTrue;16public class SingleListeningTest {17    private GenericContainer<?> container = new GenericContainer<>("alpine:3.8")18            .withCommand("sh", "-c", "while true; do echo 'HTTP/1.1 200 OK'; echo; echo 'Hello, world!'; sleep 1; done")19            .withExposedPorts(80)20            .waitingFor(Wait.forHttp("/"));21    void shouldWaitForHttp() throws IOException, URISyntaxException {22        URI uri = container.getHttpHostPort(80);23        String response = new String(container.execInContainer("wget", "-q", "-O", "-", uri.toString()).getStdout(), StandardCharsets.UTF_8);24        assertThat(response, containsString("Hello, world!"));25    }26    void shouldWaitForListeningPort() throws IOException, InterruptedException {27        int port = container.getMappedPort(80);28        assertTrue("Port is listening", singleListening(port, 10, TimeUnit.SECONDS));29    }30    private boolean singleListening(int port, long timeout, TimeUnit timeUnit) throws InterruptedException {31        long deadline = System.currentTimeMillis() + timeUnit.toMillis(timeout);32        while (System.currentTimeMillis() < deadline) {33            try (Socket ignored = new Socket("localhost", port)) {34                return true;35            } catch (IOException ignored) {36                Thread.sleep(100);37            }38        }39        return false;40    }41}42SingleListeningTest > shouldWaitForHttp() PASSED43SingleListeningTest > shouldWaitForListeningPort() PASSED

singleListening

Using AI Code Generation

1package org.testcontainers.containers.wait.internal;2import static org.rnorth.visibleassertions.VisibleAssertions.*;3import java.util.concurrent.TimeUnit;4import org.junit.Test;5import org.testcontainers.containers.GenericContainer;6import org.testcontainers.containers.wait.strategy.Wait;7public class ExternalPortListeningCheckTest {8    public void singleListening() {9        try (GenericContainer container = new GenericContainer("busybox:1.28")10            .withCommand("nc", "-l", "1234")11            .withExposedPorts(1234)12            .waitingFor(Wait.forListeningPort())) {13            container.start();14            assertIsTrue(ExternalPortListeningCheck.singleListening(container.getContainerIpAddress(), container.getMappedPort(1234), 1, TimeUnit.SECONDS));15        }16    }17}18import org.testcontainers.containers.wait.strategy.Wait;19import static org.rnorth.visibleassertions.VisibleAssertions.*;20import org.junit.Test;21import org.testcontainers.containers.GenericContainer;22public class ExternalPortListeningCheckTest {23    public void singleListening() {24        try (GenericContainer container = new GenericContainer("busybox:1.28")25            .withCommand("nc", "-l", "1234")26            .withExposedPorts(1234)27            .waitingFor(Wait.forListeningPort())) {28            container.start();29            assertIsTrue(ExternalPortListeningCheck.singleListening(container.getContainerIpAddress(), container.getMappedPort(1234), 1, TimeUnit.SECONDS));30        }31    }32}33import static org.rnorth.visibleassertions.VisibleAssertions.*;34import org.junit.Test;35import org.testcontainers.containers.GenericContainer;36import org.testcontainers.containers.wait.strategy.Wait;37public class ExternalPortListeningCheckTest {38    public void singleListening() {39        try (GenericContainer container = new GenericContainer("busybox:1.28")40            .withCommand("nc", "-l", "1234")41            .withExposedPorts(1234)42            .waitingFor(Wait.forListeningPort())) {43            container.start();44            assertIsTrue(ExternalPortListeningCheck.singleListening(container.getContainerIpAddress(), container.getMappedPort(1234), 1, TimeUnit.SECONDS));45        }46    }47}48import org.junit.Test;49import org.testcontainers.containers.GenericContainer;50import org.testcontainers.containers.wait.strategy.Wait;51import static org.rnorth.visibleassertions.VisibleAssertions.*;52public class ExternalPortListeningCheckTest {

singleListening

Using AI Code Generation

1import org.junit.Test;2import org.testcontainers.containers.GenericContainer;3import org.testcontainers.containers.wait.strategy.Wait;4public class SingleListeningTest {5    public void testSingleListening() throws Exception {6        try (final GenericContainer container = new GenericContainer("alpine:3.6")7                .withExposedPorts(80)8                .waitingFor(Wait.forListeningPort())) {9            container.start();10            container.waitingFor(new ExternalPortListeningCheckTest.SingleListeningCheck(80));11        }12    }13}14import org.junit.Test;15import org.testcontainers.containers.GenericContainer;16import org.testcontainers.containers.wait.strategy.Wait;17public class SingleListeningTest {18    public void testSingleListening() throws Exception {19        try (final GenericContainer container = new GenericContainer("alpine:3.6")20                .withExposedPorts(80)21                .waitingFor(Wait.forListeningPort())) {22            container.start();23            container.waitingFor(new ExternalPortListeningCheckTest.SingleListeningCheck(80));24        }25    }26}27public class SingleListeningCheck extends ExternalPortListeningCheck {28    private final int port;29    public SingleListeningCheck(final int port) {30        this.port = port;31    }32    protected Set<Integer> getPortsToCheck() {33        return Collections.singleton(port);34    }35}36public class SingleListeningCheck extends ExternalPortListeningCheck {37    private final int port;38    public SingleListeningCheck(final int port) {39        this.port = port;40    }41    protected Set<Integer> getPortsToCheck() {42        return Collections.singleton(port);43    }44}45import org.junit.Test;46import org.testcontainers.containers.GenericContainer;47import org.testcontainers.containers.wait.strategy.Wait;48public class SingleListeningTest {49    public void testSingleListening() throws Exception {50        try (final GenericContainer container = new GenericContainer("alpine:3.6")51                .withExposedPorts(80)52                .waitingFor(Wait.forListeningPort())) {53            container.start();54            container.waitingFor(new ExternalPortListeningCheckTest.SingleListeningCheck(80));55        }56    }57}

singleListening

Using AI Code Generation

1import org.testcontainers.containers.wait.strategy.Wait2import org.testcontainers.containers.wait.strategy.WaitStrategy3import org.testcontainers.containers.wait.strategy.WaitStrategyTarget4import java.time.Duration5public class SingleListeningCheck implements WaitStrategy {6    private final String host;7    private final int port;8    private final Duration startupTimeout;9    public SingleListeningCheck(String host, int port, Duration startupTimeout) {10        this.host = host;11        this.port = port;12        this.startupTimeout = startupTimeout;13    }14    public void waitUntilReady(WaitStrategyTarget waitStrategyTarget) {15        new ExternalPortListeningCheckTest().singleListening(host, port, startupTimeout);16    }17}18public class ExternalPortListeningCheckTest {19    public void singleListening() {20        singleListening("localhost", 8080, Duration.ofSeconds(5));21    }22    public void singleListening(String host, int port, Duration startupTimeout) {23        try {24            new Socket(host, port).close();25        } catch (IOException e) {26            throw new IllegalStateException("Could not connect to port " + port + " on host " + host + " within " + startupTimeout.getSeconds() + " seconds", e);27        }28    }29}30	at org.testcontainers.containers.wait.strategy.ExternalPortListeningCheckTest.singleListening(ExternalPortListeningCheckTest.java:19)31	at org.testcontainers.containers.wait.strategy.SingleListeningCheck.waitUntilReady(SingleListeningCheck.java:19)32	at org.testcontainers.containers.wait.strategy.WaitAllStrategy.waitUntilReady(WaitAllStrategy.java:36)33	at org.testcontainers.containers.GenericContainer.waitUntilContainerStarted(GenericContainer.java:920)34	at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:436)35	at org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:323)

singleListening

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer2import org.testcontainers.containers.wait.strategy.Wait3import static org.testcontainers.containers.wait.strategy.Wait.forListeningPort4def container = new GenericContainer("alpine:3.5")5    .withCommand("nc", "-ll", "-p", "12345")6    .waitingFor(forListeningPort())7    .withStartupTimeout(Duration.ofSeconds(5))8    .start()9def result = container.waitingFor.waitUntilReady()10container.stop()

singleListening

Using AI Code Generation

1org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening("localhost", 8080, 1000)2org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening("localhost", 8080, 1000)3org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening("localhost", 8080, 1000)4org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening("localhost", 8080, 1000)5org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening("localhost", 8080, 1000)6org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening("localhost", 8080, 1000)7org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening("localhost", 8080, 1000)8org.testcontainers.containers.wait.internal.ExternalPortListeningCheckTest.singleListening("localhost", 8080, 1000)

singleListening

Using AI Code Generation

1public static void main(String[] args) {2    ExternalPortListeningCheck check = new ExternalPortListeningCheck(8080, 2);3    try {4        check.waitUntilReady(new GenericContainer());5    } catch (IllegalStateException e) {6        System.out.println("Container is not listening on port 8080");7    }8}9container.stop()

singleListening

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer2import org.testcontainers.containers.wait.strategy.Wait3import static org.testcontainers.containers.wait.strategy.Wait.forListeningPort4def container = new GenericContainer("alpine:3.5")5    .withCommand("nc", "-ll", "-p", "12345")6    .waitingFor(forListeningPort())7    .withStartupTimeout(Duration.ofSeconds(5))8    .start()9def result = container.waitingFor.waitUntilReady()10container.stop()

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.