Examples of org.apache.provisionr.core.logging.StreamLogger

        final List<String> lines = Lists.newCopyOnWriteArrayList();


        final byte[] bytes = "line1\nline2\nline3".getBytes(Charsets.UTF_8);
        ByteArrayInputStream inputStream = new ByteArrayInputStream(bytes);


        final StreamLogger logger = new StreamLogger(inputStream, LOG, MarkerFactory.getMarker("test")) {
            @Override
            protected void log(Logger logger, Marker marker, String line) {
                logger.info(marker, line);  /* just for visual inspection */
                lines.add(line);
            }
        };
        logger.start();


        logger.join();
        assertThat(lines).contains("line1", "line2", "line3");
    }

            Session session = client.startSession();
            try {
                final Session.Command command = session.exec("echo 'line1' && echo && echo 'line2'");
                final List<String> lines = Lists.newCopyOnWriteArrayList();


                StreamLogger logger = new StreamLogger(command.getInputStream(), LOG, MarkerFactory.getMarker("live")) {
                    @Override
                    protected void log(Logger logger, Marker marker, String line) {
                        logger.info(marker, line);  /* just for visual inspection */
                        lines.add(line);
                    }
                };
                logger.start();


                command.join();
                logger.join();


                assertThat(lines).hasSize(2).contains("line1", "line2");


            } finally {
                session.close();

Related Classes of org.apache.provisionr.core.logging.StreamLogger

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.