1 17 18 package org.objectweb.jac.util; 19 20 import java.io.BufferedReader ; 21 import java.io.InputStream ; 22 import java.io.InputStreamReader ; 23 import java.io.OutputStream ; 24 import java.io.OutputStreamWriter ; 25 import java.io.PrintWriter ; 26 import java.io.Reader ; 27 import java.io.Writer ; 28 import org.apache.log4j.Logger; 29 30 31 35 public class Pipe extends Thread 36 { 37 static Logger logger = Logger.getLogger("util.pipe"); 38 39 44 public Pipe(Reader input, Writer output) { 45 this.input = new BufferedReader (input); 46 this.output = new PrintWriter (output); 47 } 48 49 54 public Pipe(InputStream input, OutputStream output) { 55 this.input = new BufferedReader (new InputStreamReader (input)); 56 this.output = new PrintWriter (new OutputStreamWriter (output)); 57 } 58 59 BufferedReader input; 60 PrintWriter output; 61 62 public void run() { 63 try { 64 String line; 65 while ((line=input.readLine())!=null) { 66 System.out.println(line); 67 } 70 } catch(Exception e) { 71 logger.error("Caught exception in Pipe thread: "+e); 72 } 73 } 74 } 75 | Popular Tags |