Class StreamPumper
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.maven.shared.utils.cli.AbstractStreamHandler
-
- org.apache.maven.shared.utils.cli.StreamPumper
-
- All Implemented Interfaces:
java.lang.Runnable
public class StreamPumper extends AbstractStreamHandler
Class to pump the error stream during Process's runtime. Copied from the Ant built-in task.
-
-
Field Summary
Fields Modifier and Type Field Description private StreamConsumer
consumer
private java.lang.Exception
exception
private java.io.BufferedReader
in
private static int
SIZE
-
Constructor Summary
Constructors Modifier Constructor Description StreamPumper(java.io.InputStream in, StreamConsumer consumer)
StreamPumper(java.io.InputStream in, StreamConsumer consumer, java.nio.charset.Charset charset)
private
StreamPumper(java.io.Reader in, StreamConsumer consumer)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description void
close()
Deprecated.As of 3.2.0, removed without replacement.private void
consumeLine(java.lang.String line)
void
flush()
Deprecated.As of 3.2.0, removed without replacement.java.lang.Exception
getException()
void
run()
run it.-
Methods inherited from class org.apache.maven.shared.utils.cli.AbstractStreamHandler
disable, isDisabled, isDone, setDone, waitUntilDone
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
in
private final java.io.BufferedReader in
-
consumer
private final StreamConsumer consumer
-
exception
private volatile java.lang.Exception exception
-
SIZE
private static final int SIZE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
StreamPumper
public StreamPumper(java.io.InputStream in, StreamConsumer consumer)
- Parameters:
in
-InputStream
consumer
-StreamConsumer
-
StreamPumper
public StreamPumper(java.io.InputStream in, StreamConsumer consumer, @Nullable java.nio.charset.Charset charset)
- Parameters:
in
-InputStream
consumer
-StreamConsumer
charset
-Charset
-
StreamPumper
private StreamPumper(java.io.Reader in, StreamConsumer consumer)
- Parameters:
in
-Reader
consumer
-StreamConsumer
-
-
Method Detail
-
run
public void run()
run it.- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
flush
@Deprecated public void flush()
Deprecated.As of 3.2.0, removed without replacement.flush.
-
close
@Deprecated public void close()
Deprecated.As of 3.2.0, removed without replacement.Close it.
-
getException
public java.lang.Exception getException()
- Returns:
Exception
-
consumeLine
private void consumeLine(java.lang.String line) throws java.io.IOException
- Throws:
java.io.IOException
-
-