KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > openedit > archive > update > StreamGobbler


1 package com.openedit.archive.update;
2
3 import java.io.BufferedReader JavaDoc;
4 import java.io.IOException JavaDoc;
5 import java.io.InputStream JavaDoc;
6 import java.io.InputStreamReader JavaDoc;
7 import java.util.Vector JavaDoc;
8
9 import org.apache.commons.logging.Log;
10 import org.apache.commons.logging.LogFactory;
11
12 class StreamGobbler extends Thread JavaDoc {
13     private static final Log log = LogFactory.getLog(StreamGobbler.class);
14
15     InputStream JavaDoc is;
16
17     String JavaDoc type;
18
19     Vector JavaDoc output;
20
21     StreamGobbler(InputStream JavaDoc is, String JavaDoc type, Vector JavaDoc collectingParameter) {
22         this.is = is;
23         this.type = type;
24         this.output = collectingParameter;
25     }
26
27     public void run() {
28         try {
29             BufferedReader JavaDoc reader = new BufferedReader JavaDoc(
30                     new InputStreamReader JavaDoc(is));
31             String JavaDoc line = null;
32             while ((line = reader.readLine()) != null)
33                 output.addElement(type + ">" + line);
34         } catch (IOException JavaDoc x) {
35             String JavaDoc out = type + "> error: " + x.getMessage();
36             output.addElement(out);
37             log.error(out);
38         }
39     }
40 }
41
Popular Tags