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

Class ThreadedStreamConsumer

java.lang.Object

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

All Implemented Interfaces:

org.apache.maven.shared.utils.cli.StreamConsumer

public final class ThreadedStreamConsumer
extends java.lang.Object
implements org.apache.maven.shared.utils.cli.StreamConsumer

Knows how to reconstruct *all* the state transmitted over stdout by the forked process.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	ThreadedStreamConsumer.Pumper

Field Summary

Fields

Modifier and Type	Field and Description
private static int	ITEM_LIMIT_BEFORE_SLEEP
private java.util.concurrent.BlockingQueue<java.lang.String>	items
private static java.lang.String	POISON
private ThreadedStreamConsumer.Pumper	pumper
private java.lang.Thread	thread

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
void	consumeLine(java.lang.String s)

Methods inherited from class java.lang.Object

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

Field Detail

POISON

private static final java.lang.String POISON

See Also:

Constant Field Values

ITEM_LIMIT_BEFORE_SLEEP

private static final int ITEM_LIMIT_BEFORE_SLEEP

See Also:

Constant Field Values

items

private final java.util.concurrent.BlockingQueue<java.lang.String> items

thread

private final java.lang.Thread thread

pumper

private final ThreadedStreamConsumer.Pumper pumper

Constructor Detail

ThreadedStreamConsumer

public ThreadedStreamConsumer(org.apache.maven.shared.utils.cli.StreamConsumer target)

Method Detail

consumeLine

public void consumeLine(java.lang.String s)

Specified by:

consumeLine in interface org.apache.maven.shared.utils.cli.StreamConsumer

close

public void close()