Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

brooklyn.util.stream
[Java] Class StreamGobbler

java.lang.Object
  java.lang.Thread
      brooklyn.util.stream.StreamGobbler
All Implemented Interfaces:
java.io.Closeable
public class StreamGobbler
extends java.lang.Thread
Field Summary
protected Logger log

protected java.io.PrintStream out

protected java.io.InputStream stream

 
Fields inherited from class java.lang.Thread
MIN_PRIORITY, NORM_PRIORITY, MAX_PRIORITY
 
Constructor Summary
StreamGobbler(java.io.InputStream stream, java.io.OutputStream out, Logger log)

StreamGobbler(java.io.InputStream stream, java.io.PrintStream out, Logger log)

 
Method Summary
void blockUntilFinished()

convenience -- similar to !
void close()

boolean isFinished()

void onChar(int c)

void onClose()

void onLine(java.lang.String line)

void run()

StreamGobbler setLogPrefix(java.lang.String prefix)

StreamGobbler setPrefix(java.lang.String prefix)

StreamGobbler setPrintPrefix(java.lang.String prefix)

void shutdown()

@deprecate Use close() instead.
 
Methods inherited from class java.lang.Thread
java.lang.Thread#run(), java.lang.Thread#toString(), java.lang.Thread#isInterrupted(), java.lang.Thread#currentThread(), java.lang.Thread#getName(), java.lang.Thread#getThreadGroup(), java.lang.Thread#getStackTrace(), java.lang.Thread#dumpStack(), java.lang.Thread#setPriority(int), java.lang.Thread#setDaemon(boolean), java.lang.Thread#start(), java.lang.Thread#yield(), java.lang.Thread#sleep(long), java.lang.Thread#sleep(long, int), java.lang.Thread#stop(), java.lang.Thread#stop(java.lang.Throwable), java.lang.Thread#interrupt(), java.lang.Thread#interrupted(), java.lang.Thread#destroy(), java.lang.Thread#isAlive(), java.lang.Thread#suspend(), java.lang.Thread#resume(), java.lang.Thread#getPriority(), java.lang.Thread#setName(java.lang.String), java.lang.Thread#activeCount(), java.lang.Thread#enumerate([Ljava.lang.Thread;), java.lang.Thread#countStackFrames(), java.lang.Thread#join(), java.lang.Thread#join(long, int), java.lang.Thread#join(long), java.lang.Thread#isDaemon(), java.lang.Thread#checkAccess(), java.lang.Thread#getContextClassLoader(), java.lang.Thread#setContextClassLoader(java.lang.ClassLoader), java.lang.Thread#holdsLock(java.lang.Object), java.lang.Thread#getAllStackTraces(), java.lang.Thread#getId(), java.lang.Thread#getState(), java.lang.Thread#setDefaultUncaughtExceptionHandler(java.lang.Thread$UncaughtExceptionHandler), java.lang.Thread#getDefaultUncaughtExceptionHandler(), java.lang.Thread#getUncaughtExceptionHandler(), java.lang.Thread#setUncaughtExceptionHandler(java.lang.Thread$UncaughtExceptionHandler), java.lang.Thread#wait(), java.lang.Thread#wait(long), java.lang.Thread#wait(long, int), java.lang.Thread#equals(java.lang.Object), java.lang.Thread#hashCode(), java.lang.Thread#getClass(), java.lang.Thread#notify(), java.lang.Thread#notifyAll()
 
Methods inherited from class java.lang.Object
java.lang.Object#wait(), java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

Field Detail

log

protected final Logger log

out

protected final java.io.PrintStream out

stream

protected final java.io.InputStream stream

 
Constructor Detail

StreamGobbler

public StreamGobbler(java.io.InputStream stream, java.io.OutputStream out, Logger log)

StreamGobbler

public StreamGobbler(java.io.InputStream stream, java.io.PrintStream out, Logger log)

 
Method Detail

blockUntilFinished

public void blockUntilFinished()
convenience -- similar to !Thread.isAlive()

close

@Override
public void close()

isFinished

public boolean isFinished()

onChar

public void onChar(int c)

onClose

public void onClose()

onLine

public void onLine(java.lang.String line)

run

@Override
public void run()

setLogPrefix

public StreamGobbler setLogPrefix(java.lang.String prefix)

setPrefix

public StreamGobbler setPrefix(java.lang.String prefix)

setPrintPrefix

public StreamGobbler setPrintPrefix(java.lang.String prefix)

shutdown

@Deprecated
public void shutdown()
deprecate:
Use close() instead.

 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.