1 package org.columba.core.base; 17 18 import java.io.BufferedReader ; 19 import java.io.IOException ; 20 import java.io.InputStream ; 21 import java.io.InputStreamReader ; 22 import java.util.logging.Logger ; 23 24 25 public class StreamThread extends Thread { 26 27 private static final Logger LOG = Logger.getLogger("org.columba.core.base"); 29 InputStream is; 30 String type; 31 StringBuffer buf; 32 33 public StreamThread(InputStream theInputStream, String theType) { 34 this.is = theInputStream; 35 this.type = theType; 36 37 buf = new StringBuffer (); 38 } 39 40 @Override  41 public void run() { 42 try { 43 InputStreamReader isr = new InputStreamReader (is); 44 BufferedReader br = new BufferedReader (isr); 45 String line = null; 46 47 while ((line = br.readLine()) != null) { 48 LOG.fine(type + ">" + line); buf.append(line + "\n"); } 51 } catch (IOException ioe) { 52 ioe.printStackTrace(); 53 } 54 } 55 56 public String getBuffer() { 57 return buf.toString(); 58 } 59 } 60 | Popular Tags |