com.atlassian.bamboo.command
Class StreamToLogsPumper

java.lang.Object
  com.atlassian.bamboo.command.StreamToLogsPumper

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

ErrorStreamToLogsPumper

public class StreamToLogsPumper
extends java.lang.Object
implements java.lang.Runnable

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

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

Field Summary

protected BuildLogger	buildLogger
protected java.lang.String	planKey

Constructor Summary

StreamToLogsPumper(java.io.InputStream inputStream, BuildLogger buildLogger, java.lang.String planKey)
Pump the given inputStream into the given outputList

StreamToLogsPumper(java.io.InputStream inputStream, BuildLogger buildLogger, java.lang.String planKey, boolean filterDownloadStatusMessages)

Method Summary

protected void	log(java.lang.String line)
protected void	pump(java.io.BufferedReader reader) Pump the reader into logs
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 Detail

buildLogger

protected final BuildLogger buildLogger

planKey

protected final java.lang.String planKey

Constructor Detail

StreamToLogsPumper

public StreamToLogsPumper(java.io.InputStream inputStream,
                          BuildLogger buildLogger,
                          java.lang.String planKey)

Pump the given inputStream into the given outputList

Parameters:

inputStream - input data stream

buildLogger -

planKey -

StreamToLogsPumper

public StreamToLogsPumper(java.io.InputStream inputStream,
                          BuildLogger buildLogger,
                          java.lang.String planKey,
                          boolean filterDownloadStatusMessages)

Method Detail

run

public void run()

Convert the input stream into a list within the thread

Specified by:

run in interface java.lang.Runnable

pump

protected void pump(java.io.BufferedReader reader)
             throws java.io.IOException

Pump the reader into logs

Parameters:

reader - The reader

Throws:

java.io.IOException - Something went wrong

log

protected void log(@NotNull
                   java.lang.String line)