Package org.apache.maven.plugin.surefire.booterclient.output

Class ThreadedStreamConsumer.Pumper

java.lang.Object

org.apache.maven.plugin.surefire.booterclient.output.ThreadedStreamConsumer.Pumper

All Implemented Interfaces:

Runnable

Enclosing class:

ThreadedStreamConsumer

final class ThreadedStreamConsumer.Pumper
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private final MultipleFailureException	errors
private final org.apache.maven.shared.utils.cli.StreamConsumer	target

Constructor Summary

Constructors

Constructor	Description
Pumper(org.apache.maven.shared.utils.cli.StreamConsumer target)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	hasErrors()
void	run()	Calls ForkClient.consumeLine(String) which may throw any RuntimeException. Even if ForkClient is not fault-tolerant, this method MUST be fault-tolerant and thus the try-catch block must be inside of the loop which prevents from loosing events from StreamConsumer.
(package private) void	throwErrors()

Methods inherited from class java.lang.Object

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

Field Details

target

private final org.apache.maven.shared.utils.cli.StreamConsumer target

errors

private final MultipleFailureException errors

Constructor Details

Pumper

Pumper(org.apache.maven.shared.utils.cli.StreamConsumer target)

Method Details

run

public void run()

Calls ForkClient.consumeLine(String) which may throw any RuntimeException.
Even if ForkClient is not fault-tolerant, this method MUST be fault-tolerant and thus the try-catch block must be inside of the loop which prevents from loosing events from StreamConsumer.
If ConsoleOutputFileReporter.writeTestOutput(java.lang.String, boolean, boolean) throws IOException and then target.consumeLine() throws any RuntimeException, this method MUST NOT skip reading the events from the forked JVM; otherwise we could simply lost events e.g. acquire-next-test which means that ForkClient could hang on waiting for old test to complete and therefore the plugin could be permanently in progress.

Specified by:

run in interface Runnable

hasErrors

boolean hasErrors()

throwErrors

void throwErrors()
          throws IOException

Throws:

IOException