How to use withSeparateOutputStreams method of org.testcontainers.containers.output.Slf4jLogConsumer class

Best Testcontainers-java code snippet using org.testcontainers.containers.output.Slf4jLogConsumer.withSeparateOutputStreams

Source:InventoryIT.java

...57    RestAssured.reset();58    RestAssured.enableLoggingOfRequestAndResponseIfValidationFails();59    RestAssured.baseURI = "http://" + MOD_INVENTORY.getHost() + ":" + MOD_INVENTORY.getFirstMappedPort();60    if (IS_LOG_ENABLED) {61      KAFKA.followOutput(new Slf4jLogConsumer(LOG).withSeparateOutputStreams());62      MOD_INVENTORY.followOutput(new Slf4jLogConsumer(LOG).withSeparateOutputStreams());63    }64  }65  @BeforeEach66  void beforeEach() {67    RestAssured.requestSpecification = null;  // unset X-Okapi-Tenant etc.68  }69  @Test70  void health() {71    // request without X-Okapi-Tenant72    when().73      get("/admin/health").74    then().75      statusCode(200).76      body(is("OK"))....

Source:InstallUpgradeIT.java

...46    RestAssured.reset();47    RestAssured.enableLoggingOfRequestAndResponseIfValidationFails();48    RestAssured.baseURI = "http://" + MOD_ORDERS.getHost() + ":" + MOD_ORDERS.getFirstMappedPort();49    if (IS_LOG_ENABLED) {50      KAFKA.followOutput(new Slf4jLogConsumer(LOG).withSeparateOutputStreams());51      MOD_ORDERS.followOutput(new Slf4jLogConsumer(LOG).withSeparateOutputStreams());52    }53  }54  @Before55  public void beforeEach() {56    RestAssured.requestSpecification = null;57  }58  @Test59  public void health() {60    // request without X-Okapi-Tenant61    when().62      get("/admin/health").63      then().64      statusCode(200).65      body(is("\"OK\""));...

Source:MySqlTestContainer.java

...19    20    // https://github.com/testcontainers/testcontainers-java/issues/235221    static {22        mysqlContainer.start();23        mysqlContainer.followOutput(new Slf4jLogConsumer(log).withSeparateOutputStreams());24    }25    @DynamicPropertySource26    static void setDataSourceUrl(DynamicPropertyRegistry registry) {27        registry.add("spring.datasource.initialization-mode", () -> "never");28        registry.add("spring.datasource.url", mysqlContainer::getJdbcUrl);29        registry.add("spring.datasource.username", mysqlContainer::getUsername);30        registry.add("spring.datasource.password", mysqlContainer::getPassword);31    }32}...

withSeparateOutputStreams

Using AI Code Generation

1package org.testcontainers.containers.output;2import org.junit.Test;3import org.slf4j.Logger;4import org.slf4j.LoggerFactory;5import org.testcontainers.containers.GenericContainer;6public class Slf4jLogConsumerTest {7    private static final Logger log = LoggerFactory.getLogger(Slf4jLogConsumerTest.class);8    public void testSlf4jLogConsumer() {9        GenericContainer container = new GenericContainer("alpine:3.6")10                .withCommand("sh", "-c", "echo 'Hello World' && sleep 1000")11                .withLogConsumer(new Slf4jLogConsumer(log).withSeparateOutputStreams());12        container.start();13    }14}

withSeparateOutputStreams

Using AI Code Generation

1package org.testcontainers.containers.output;2import org.slf4j.Logger;3import org.slf4j.LoggerFactory;4import org.testcontainers.containers.Container;5import org.testcontainers.containers.ContainerLaunchException;6import org.testcontainers.containers.output.OutputFrame.OutputType;7import java.io.IOException;8import java.io.OutputStream;9import java.nio.charset.Charset;10public class Slf4jLogConsumer implements LogConsumer {11    private static final Logger logger = LoggerFactory.getLogger(Slf4jLogConsumer.class);12    private final Charset outputFrameCharset;13    private final OutputStream standardOutputStream;14    private final OutputStream errorOutputStream;15    public Slf4jLogConsumer(Logger logger) {16        this(logger, Charset.defaultCharset());17    }18    public Slf4jLogConsumer(Logger logger, Charset outputFrameCharset) {19        this(logger, outputFrameCharset, new Slf4jOutputStream(logger, LogLevel.INFO), new Slf4jOutputStream(logger, LogLevel.ERROR));20    }21    public Slf4jLogConsumer(Logger logger, Charset outputFrameCharset, OutputStream standardOutputStream, OutputStream errorOutputStream) {22        this.outputFrameCharset = outputFrameCharset;23        this.standardOutputStream = standardOutputStream;24        this.errorOutputStream = errorOutputStream;25    }26    public void accept(OutputFrame outputFrame) {27        try {28            switch (outputFrame.getType()) {29                    standardOutputStream.write(outputFrame.getBytes());30                    break;31                    errorOutputStream.write(outputFrame.getBytes());32                    break;33                    throw new ContainerLaunchException("Unexpected output type: " + outputFrame.getType());34            }35        } catch (IOException e) {36            throw new ContainerLaunchException("Could not write frame to log", e);37        }38    }39    public void finish() {40        try {41            standardOutputStream.flush();42            errorOutputStream.flush();43        } catch (IOException e) {44            throw new ContainerLaunchException("Could not flush output streams", e);45        }46    }47    private static class Slf4jOutputStream extends OutputStream {48        private final Logger logger;49        private final LogLevel logLevel;50        private Slf4jOutputStream(Logger logger, LogLevel logLevel) {51            this.logger = logger;52            this.logLevel = logLevel;53        }54        public void write(int b) throws IOException {55            logLevel.log(logger, String.valueOf((char) b));56        }57    }

withSeparateOutputStreams

Using AI Code Generation

1package com.testcontainers;2import org.junit.jupiter.api.Test;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.output.Slf4jLogConsumer;5import org.testcontainers.utility.DockerImageName;6import java.io.IOException;7public class TestContainer {8    public void testContainer() throws IOException, InterruptedException {9        GenericContainer container = new GenericContainer(DockerImageName.parse("redis:6.0.10"))10                .withExposedPorts(6379)11                .withLogConsumer(new Slf4jLogConsumer().withSeparateOutputStreams());12        container.start();13        System.out.println(container.getMappedPort(6379));14        Thread.sleep(5000);15        container.stop();16    }17}18package com.testcontainers;19import org.junit.jupiter.api.Test;20import org.testcontainers.containers.GenericContainer;21import org.testcontainers.containers.output.Slf4jLogConsumer;22import org.testcontainers.utility.DockerImageName;23import java.io.IOException;24public class TestContainer {25    public void testContainer() throws IOException, InterruptedException {26        GenericContainer container = new GenericContainer(DockerImageName.parse("redis:6.0.10"))27                .withExposedPorts(6379)28                .withLogConsumer(new Slf4jLogConsumer().withOutputStream(System.out).withErrorStream(System.err));29        container.start();30        System.out.println(container.getMappedPort(6379));31        Thread.sleep(5000);32        container.stop();33    }34}

withSeparateOutputStreams

Using AI Code Generation

1package com.example;2import org.junit.Test;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.output.Slf4jLogConsumer;5import java.io.IOException;6public class TestContainer {7    public void test() throws IOException, InterruptedException {8        Slf4jLogConsumer logConsumer = new Slf4jLogConsumer();9        GenericContainer container = new GenericContainer("alpine:3.7")10                .withCommand("tail", "-f", "/dev/null")11                .withLogConsumer(logConsumer.withSeparateOutputStreams());12        container.start();13        Thread.sleep(5000);14    }15}16package com.example;17import org.junit.Test;18import org.testcontainers.containers.GenericContainer;19import org.testcontainers.containers.output.Slf4jLogConsumer;20import java.io.IOException;21public class TestContainer {22    public void test() throws IOException, InterruptedException {23        Slf4jLogConsumer logConsumer = new Slf4jLogConsumer();24        GenericContainer container = new GenericContainer("alpine:3.7")25                .withCommand("tail", "-f", "/dev/null")26                .withLogConsumer(logConsumer.withOutputStream(System.out));27        container.start();28        Thread.sleep(5000);29    }30}31package com.example;32import org.junit.Test;33import org.testcontainers.containers.GenericContainer;34import org.testcontainers.containers.output.Slf4jLogConsumer;35import java.io.IOException;36public class TestContainer {37    public void test() throws IOException, InterruptedException {38        Slf4jLogConsumer logConsumer = new Slf4jLogConsumer();39        GenericContainer container = new GenericContainer("alpine:3.7")40                .withCommand("tail", "-f", "/dev/null")41                .withLogConsumer(logConsumer.withErrorStream(System.err));42        container.start();43        Thread.sleep(5000);44    }45}46package com.example;47import org.junit.Test;48import org.testcontainers.containers.GenericContainer;49import org.testcontainers.containers

withSeparateOutputStreams

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.output.Slf4jLogConsumer;3public class TestContainer {4    public static void main(String[] args) {5        GenericContainer container = new GenericContainer("alpine:3.9")6                .withCommand("sh", "-c", "echo 'Hello World'; echo 'Hello Error' 1>&2")7                .withLogConsumer(new Slf4jLogConsumer().withSeparateOutputStreams());8        container.start();9    }10}11import org.testcontainers.containers.GenericContainer;12import org.testcontainers.containers.output.Slf4jLogConsumer;13public class TestContainer {14    public static void main(String[] args) {15        GenericContainer container = new GenericContainer("alpine:3.9")16                .withCommand("sh", "-c", "echo 'Hello World'; echo 'Hello Error' 1>&2")17                .withLogConsumer(new Slf4jLogConsumer().withPrefix("myPrefix"));18        container.start();19    }20}21import org.testcontainers.containers.GenericContainer;22import org.testcontainers.containers.output.Slf4jLogConsumer;23import java.io.File;24import java.io.FileOutputStream;25import java.io.IOException;26import java.io.OutputStream;27public class TestContainer {28    public static void main(String[] args) {29        try {30            File file = new File("output.txt");31            OutputStream outputStream = new FileOutputStream(file);32            GenericContainer container = new GenericContainer("alpine:3.9")33                    .withCommand("sh", "-c", "echo 'Hello World'; echo 'Hello Error' 1>&2")34                    .withLogConsumer(new Slf4jLogConsumer().withOutputStream(outputStream));35            container.start();36        } catch (IOException e) {37            e.printStackTrace();38        }39    }40}

withSeparateOutputStreams

Using AI Code Generation

1package org.testcontainers.demo;2import org.junit.Test;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.output.Slf4jLogConsumer;5import java.io.IOException;6public class DemoTest {7    public void test() throws IOException, InterruptedException {8        Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(System.out);9        GenericContainer container = new GenericContainer("alpine:3.7")10                .withCommand("sh", "-c", "echo 'Hello World!' && sleep 5")11                .withLogConsumer(logConsumer.withSeparateOutputStreams());12        container.start();13        container.followOutput(logConsumer);14    }15}16package org.testcontainers.demo;17import org.junit.Test;18import org.testcontainers.containers.GenericContainer;19import org.testcontainers.containers.output.Slf4jLogConsumer;20import java.io.IOException;21public class DemoTest {22    public void test() throws IOException, InterruptedException {23        Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(System.out);24        GenericContainer container = new GenericContainer("alpine:3.7")25                .withCommand("sh", "-c", "echo 'Hello World!' && sleep 5")26                .withLogConsumer(logConsumer.withOutputStream(System.out));27        container.start();28        container.followOutput(logConsumer);29    }30}31package org.testcontainers.demo;32import org.junit.Test;33import org.testcontainers.containers.GenericContainer;34import org.testcontainers.containers.output.Slf4jLogConsumer;35import java.io.IOException;36public class DemoTest {37    public void test() throws IOException, InterruptedException {38        Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(System.out);

withSeparateOutputStreams

Using AI Code Generation

1public class TestContainerLoggers {2    public void testWithSeparateOutputStreams() {3        final GenericContainer container = new GenericContainer("busybox:latest")4                .withCommand("ping", "-c", "10", "localhost")5                .withSeparateOutputStreams();6        container.start();7        final String containerId = container.getContainerId();8        final Slf4jLogConsumer containerStdout = new Slf4jLogConsumer(log).withSeparateOutputStreams();9        final Slf4jLogConsumer containerStderr = new Slf4jLogConsumer(log).withSeparateOutputStreams();10        container.followOutput(containerStdout, containerStderr);11        final String stdout = containerStdout.getOutputFrame().getUtf8String();12        final String stderr = containerStderr.getOutputFrame().getUtf8String();13        log.info("Container {} stdout: {}", containerId, stdout);14        log.info("Container {} stderr: {}", containerId, stderr);15    }16}17public class TestContainerLoggers {18    public void testWithOutputStreams() {19        final GenericContainer container = new GenericContainer("busybox:latest")20                .withCommand("ping", "-c", "10", "localhost")21                .withOutputStreams();22        container.start();23        final String containerId = container.getContainerId();24        final Slf4jLogConsumer containerLogConsumer = new Slf4jLogConsumer(log).withOutputStreams();25        container.followOutput(containerLogConsumer);26        final String output = containerLogConsumer.getOutputFrame().getUtf8String();27        log.info("Container {} output: {}", containerId, output);28    }29}30public class TestContainerLoggers {31    public void testWithPrefix() {32        final GenericContainer container = new GenericContainer("busybox:latest")33                .withCommand("ping", "-c", "10", "localhost")

withSeparateOutputStreams

Using AI Code Generation

1import org.testcontainers.containers.output.Slf4jLogConsumer;2import org.testcontainers.containers.output.OutputFrame;3public class Test {4    public static void main(String[] args) {5        Slf4jLogConsumer c = new Slf4jLogConsumer(log);6        c.withSeparateOutputStreams();7        c.accept(new OutputFrame(OutputFrame.OutputType.STDOUT, "test".getBytes(), 0));8        c.accept(new OutputFrame(OutputFrame.OutputType.STDERR, "test".getBytes(), 0));9    }10}11import org.testcontainers.containers.output.Slf4jLogConsumer;12import org.testcontainers.containers.output.OutputFrame;13public class Test {14    public static void main(String[] args) {15        Slf4jLogConsumer c = new Slf4jLogConsumer(log);16        c.withSeparateOutputStreams();17        c.accept(new OutputFrame(OutputFrame.OutputType.STDOUT, "test".getBytes(), 0));18        c.accept(new OutputFrame(OutputFrame.OutputType.STDERR, "test".getBytes(), 0));19    }20}

withSeparateOutputStreams

Using AI Code Generation

1public class TestContainerLoggers {2    public void testWithSeparateOutputStreams() {3        final GenericContainer container = new GenericContainer("busybox:latest")4                .withCommand("ping", "-c", "10", "localhost")5                .withSeparateOutputStreams();6        container.start();7        final String containerId = container.getContainerId();8        final Slf4jLogConsumer containerStdout = new Slf4jLogConsumer(log).withSeparateOutputStreams();9        final Slf4jLogConsumer containerStderr = new Slf4jLogConsumer(log).withSeparateOutputStreams();10        container.followOutput(containerStdout, containerStderr);11        final String stdout = containerStdout.getOutputFrame().getUtf8String();12        final String stderr = containerStderr.getOutputFrame().getUtf8String();13        log.info("Container {} stdout: {}", containerId, stdout);14        log.info("Container {} stderr: {}", containerId, stderr);15    }16}17public class TestContainerLoggers {18    public void testWithOutputStreams() {19        final GenericContainer container = new GenericContainer("busybox:latest")20                .withCommand("ping", "-c", "10", "localhost")21                .withOutputStreams();22        container.start();23        final String containerId = container.getContainerId();24        final Slf4jLogConsumer containerLogConsumer = new Slf4jLogConsumer(log).withOutputStreams();25        container.followOutput(containerLogConsumer);26        final String output = containerLogConsumer.getOutputFrame().getUtf8String();27        log.info("Container {} output: {}", containerId, output);28    }29}30public class TestContainerLoggers {31    public void testWithPrefix() {32        final GenericContainer container = new GenericContainer("busybox:latest")33                .withCommand("ping", "-c", "10", "localhost")

withSeparateOutputStreams

Using AI Code Generation

1import org.testcontainers.containers.output.Slf4jLogConsumer;2import org.testcontainers.containers.output.OutputFrame;3public class Test {4    public static void main(String[] args) {5        Slf4jLogConsumer c = new Slf4jLogConsumer(log);6        c.withSeparateOutputStreams();7        c.accept(new OutputFrame(OutputFrame.OutputType.STDOUT, "test".getBytes(), 0));8        c.accept(new OutputFrame(OutputFrame.OutputType.STDERR, "test".getBytes(), 0));9    }10}11import org.testcontainers.containers.output.Slf4jLogConsumer;12import org.testcontainers.containers.output.OutputFrame;13public class Test {14    public static void main(String[] args) {15        Slf4jLogConsumer c = new Slf4jLogConsumer(log);16        c.withSeparateOutputStreams();17        c.accept(new OutputFrame(OutputFrame.OutputType.STDOUT, "test".getBytes(), 0));18        c.accept(new OutputFrame(OutputFrame.OutputType.STDERR, "test".getBytes(), 0));19    }20}

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.