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

Class ThreadedStreamConsumer

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.maven.shared.utils.cli.StreamConsumer

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

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) class	ThreadedStreamConsumer.Pumper

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	END_ITEM
private static int	ITEM_LIMIT_BEFORE_SLEEP
private java.util.concurrent.BlockingQueue<java.lang.String>	items
private ThreadedStreamConsumer.Pumper	pumper
private java.util.concurrent.atomic.AtomicBoolean	stop
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)
private boolean	shouldStopQueueing(java.lang.String item) Compared item with END_ITEM by identity.

Methods inherited from class java.lang.Object

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

Field Detail

END_ITEM

private static final java.lang.String END_ITEM

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

stop

private final java.util.concurrent.atomic.AtomicBoolean stop

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()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

shouldStopQueueing

private boolean shouldStopQueueing(java.lang.String item)

Compared item with END_ITEM by identity.

Parameters:

item - element from items

Returns:

true if tail of the queue