Package com.atlassian.bamboo.command

Class StreamToListPumper

java.lang.Object

com.atlassian.bamboo.command.StreamToListPumper

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

ErrorStreamToListPumper

public class StreamToListPumper
extends Object
implements Runnable

This class pumps the contents of an input stream into a list (as well as the build logs). It is designed to be executed within a thread.

Basically a variation of the Ant StreamPumper that puts in the output in a list

Field Summary

Fields

Modifier and Type	Field	Description
protected final BuildLogger	buildLogger
protected final String	planKey

Constructor Summary

Constructors

Constructor	Description
StreamToListPumper(InputStream inputStream, Collection<String> outputList, BuildLogger buildLogger, String planKey)	Pump the given inputStream into the given outputList

Method Summary

Modifier and Type	Method	Description
protected void	log(String line)
protected void	pump(BufferedReader reader)	Pump the reader into myOutputList.
void	run()	Convert the input stream into a list within the thread

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

buildLogger

protected final BuildLogger buildLogger

planKey

protected final String planKey

Constructor Details

StreamToListPumper

public StreamToListPumper(InputStream inputStream,
 Collection<String> outputList,
 BuildLogger buildLogger,
 String planKey)

Pump the given inputStream into the given outputList

Parameters:

inputStream - input data stream

outputList - resulting collection of lines

buildLogger - the logger for the build

planKey - the plankey for the build

Method Details

run

public void run()

Convert the input stream into a list within the thread

Specified by:

run in interface Runnable

pump

protected void pump(BufferedReader reader)
             throws IOException

Pump the reader into myOutputList.

Parameters:

reader - The reader

Throws:

IOException - Something went wrong

log

protected void log(String line)