Java - Capturing System.err.println or Capturing a PrintStream

Question

Hi

Java Newbie question :

I need to capture the text being written to a printStream by a 3rd party component.

The PrintStream is defaulted to System.err, but can be changed to another PrintStream.

Looking through the docs, I couldn't find an easy way to direct the contents of a PrintStream to a string writer / buffer.

Can someone please assist?

Regards

Marty

Answer 1

PipedOutputStream pipeOut = new PipedOutputStream();
PipedInputStream pipeIn = new PipedInputStream(pipeOut);
System.setOut(new PrintStream(pipeOut));
// now read from pipeIn

Answer 2

You can create a PrintStream around any other OutputStream.

The simplest way to create one that goes to a buffer in memory would be:

PrintStream p = new PrintStream( new ByteArrayOutputStream() )

Then you could read and reset the contents of the byte array at whatever points you like.

Another possibility would be to use pipes.

InputStream third_party_output = new PipedInputStream();
PrintStream p = new PrintStream( new PipedOutputStream( third_party_output ) );

Then you could read from the third_party_output stream to get the text written by the library.

Answer 3

Are you looking for something like this?

 OutputStream redirect = System.err;
 PrintStream myPrintStream = new PrintStream(redirect);
 myPrintStream.println("hello redirect");

If you can pass myPrintStream to the 3rd party application, you can redirect it anywhere you want.

Answer 4

have you tried ByteArrayOutputStream ?

Answer 5

import java.io.*;

public class Test {
    public static void main(String[] args) {
        FileOutputStream fos = null;
        try {
            fos = new FileOutputStream("errors.txt");
        } catch(IOException ioe) {
            System.err.println("redirection not possible: "+ioe);
            System.exit(-1);
        }
        PrintStream ps = new PrintStream(fos);
        System.setErr(ps);
        System.err.println("goes into file");
    }
}

Answer 6

I use the following class to log System.out and System.err to a set of rotating files (where xxx-001.log is the most recent). It contains a few call to utility methods, which you will need to implement before it will compile - they should be self-explanatory.

import java.io.*;
import java.lang.reflect.*;

public class LoggerOutputStream
extends OutputStream
{

// *****************************************************************************
// INSTANCE PROPERTIES
// *****************************************************************************

private FileOutputStream                log=null;                               // the base output stream
private String                          fnmBase,fnmExt;                         // filename base, file extension
private int                             fnmCount,fnmLast;                       // count for filename index, last filename used
private int                             logSize,totWritten;                     // max log size, current number of bytes written

// *****************************************************************************
// INSTANCE CONSTRUCTORS/INIT/CLOSE/FINALIZE
// *****************************************************************************

public LoggerOutputStream(String baseFilename) throws IOException {
    this(baseFilename,".log",2,1024000);
    }

public LoggerOutputStream(String baseFilename, String extension) throws IOException {
    this(baseFilename,extension,2,1024000);
    }

public LoggerOutputStream(String baseFilename, String extension, int numberOfFiles, int maxFileSize) throws IOException {
    fnmBase=baseFilename;
    if(Character.isLetterOrDigit(fnmBase.charAt(fnmBase.length()-1))) { fnmBase=(fnmBase+"-"); }
    fnmExt=extension;
    if(!fnmExt.startsWith(".")) { fnmExt=('.'+fnmExt); }
    fnmCount=numberOfFiles;
    logSize=maxFileSize;
    if(fnmCount>MAXLOGS) { fnmCount=MAXLOGS; }

    fnmLast=0;
    for(int xa=1; xa<=MAXLOGS; xa++) {
        if(!new File(constructFilename(xa)).exists()) {
            while((--xa)>fnmCount) { IoUtil.deleteFile(constructFilename(xa)); }
            fnmLast=xa;
            break;
            }
        }
    log=null;

    openFile(false);

    if(numberOfFiles>MAXLOGS) { System.out.println("** Log File Count Limited To "+MAXLOGS); }
    }

public void close() throws IOException {
    close(false);
    }

private void openFile(boolean ovrflw) throws IOException {
    close(true);

    if     (fnmLast< fnmCount) { fnmLast++;                                      }
    else if(fnmLast==fnmCount) { IoUtil.deleteFile(constructFilename(fnmCount)); }
    for(int xa=fnmLast; xa>0; xa--) { IoUtil.renameFile(constructFilename(xa-1),constructFilename(xa)); }
    log=new FileOutputStream(constructFilename(1));
    totWritten=0;
    }

private String constructFilename(int index) {
    return constructFilename(fnmBase,index,fnmExt);
    }

private synchronized void close(boolean ovrflw) throws IOException {
    if(log!=null) {
        log.flush();
        log.close();
        log=null;
        }
    }

// *****************************************************************************
// INSTANCE METHODS - ACCESSORS
// *****************************************************************************

public String getFilename() {
    return constructFilename(1);
    }

public String getFilename(int idx) {
    return constructFilename(idx);
    }

public synchronized void cycleLogFile() throws IOException {
    openFile(true);
    }

// *****************************************************************************
// INSTANCE METHODS
// *****************************************************************************

public synchronized void flush() throws IOException {
    if(log!=null) {
        log.flush();
        }
    }

public synchronized void write(int val) throws IOException {
    if(log!=null) {
        log.write(val);
        totWritten++;
        if(val=='\n') {
            if(totWritten>logSize) { openFile(true); }
            else                   { log.flush();    }
            }
        }
    }

public synchronized void write(byte[] bytes) throws IOException {
    if(log!=null) {
        log.write(bytes);
        totWritten+=bytes.length;
        if(bytes.length>0 && bytes[bytes.length-1]=='\n') {
            if(totWritten>logSize) { openFile(true); }
            else                   { log.flush();    }
            }
        }
    }

public synchronized void write(byte[] bytes, int str, int len) throws IOException {
    if(log!=null) {
        log.write(bytes,str,len);
        totWritten+=len;
        if(bytes.length>(str+len-1) && bytes[str+len-1]=='\n') {
            if(totWritten>logSize) { openFile(true); }
            else                   { log.flush();    }
            }
        }
    }

// *****************************************************************************
// STATIC PROPERTIES
// *****************************************************************************

static public final int                 MAXLOGS=999;                            // maximum log files allowed

// *****************************************************************************
// STATIC METHODS
// *****************************************************************************

static public String constructFilename(String bas, int idx, String ext) {
    if(!bas.endsWith("-") && !bas.endsWith("_") && !bas.endsWith(".")) { bas=(bas+"-"); }
    if(!ext.startsWith(".")                                          ) { ext=('.'+ext); }
    return (bas+TextUtil.raZeros(idx,3)+ext);
    }

} /* END PUBLIC CLASS */