package com.fdkankan.common.utils;

import java.io.*;

public class StreamGobbler extends Thread {

	InputStream is;  
    String type;  
    OutputStream os;  

    public StreamGobbler(InputStream is, String type) {  
        this(is, type, null);  
    }  

    StreamGobbler(InputStream is, String type, OutputStream redirect) {  
        this.is = is;  
        this.type = type;  
        this.os = redirect;  
    }  

    public void run() {  
        InputStreamReader isr = null;  
        BufferedReader br = null;  
        PrintWriter pw = null;  
        try {  
            if (os != null)  
                pw = new PrintWriter(os);  

            isr = new InputStreamReader(is);  
            br = new BufferedReader(isr);  
            String line=null;  
            while ( (line = br.readLine()) != null) {  
                if (pw != null)  
                    pw.println(line);  
                System.out.println(type + ">" + line);      
            }  

            if (pw != null)  
                pw.flush();  
        } catch (IOException ioe) {  
            ioe.printStackTrace();    
        } finally{  
            try {  
            	if(pw!=null)
            	{
            		 pw.close();  
            	}
            	if(br!=null)
            	{
            		br.close();  
            	}
            	if(isr!=null)
            	{
            		isr.close();  
            	}
            } catch (IOException e) {  
                e.printStackTrace();  
            }  
        }  
    }  
}