1 4 package com.tc.logging; 5 6 import com.tc.util.Assert; 7 8 import java.io.BufferedReader ; 9 import java.io.IOException ; 10 import java.io.InputStream ; 11 import java.io.InputStreamReader ; 12 13 17 public class TCStreamLogger extends Thread { 18 19 protected final BufferedReader in; 20 protected final TCLogger out; 21 protected final LogLevel level; 22 23 public TCStreamLogger(InputStream stream, TCLogger logger, LogLevel level) { 24 Assert.assertNotNull(stream); 25 26 this.in = new BufferedReader (new InputStreamReader (stream)); 27 this.out = logger; 28 this.level = level; 29 } 30 31 public void run() { 32 String line; 33 try { 34 while ((line = in.readLine()) != null) { 35 out.log(level, line); 36 } 37 } catch (IOException e) { 38 out.log(level, "Exception reading InputStream: " + e); 39 } 40 } 41 42 } | Popular Tags |