01: //The contents of this file are subject to the Mozilla Public License Version 1.1
02: //(the "License"); you may not use this file except in compliance with the
03: //License. You may obtain a copy of the License at http://www.mozilla.org/MPL/
04: //
05: //Software distributed under the License is distributed on an "AS IS" basis,
06: //WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
07: //for the specific language governing rights and
08: //limitations under the License.
09: //
10: //The Original Code is "The Columba Project"
11: //
12: //The Initial Developers of the Original Code are Frederik Dietz and Timo Stich.
13: //Portions created by Frederik Dietz and Timo Stich are Copyright (C) 2003.
14: //
15: //All Rights Reserved.
16: 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: public class StreamThread extends Thread {
25:
26: private static final Logger LOG = Logger
27: .getLogger("org.columba.core.base"); //$NON-NLS-1$
28:
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); //$NON-NLS-1$
49: buf.append(line + "\n"); //$NON-NLS-1$
50: }
51: } catch (IOException ioe) {
52: ioe.printStackTrace();
53: }
54: }
55:
56: public String getBuffer() {
57: return buf.toString();
58: }
59: }
|