Brooklyn

brooklyn.util.internal
[Java] Class StreamGobbler

java.lang.Object
  java.lang.Thread
      brooklyn.util.internal.StreamGobbler

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 -- equivalent to calling join()

boolean isFinished()

convenience -- similar to !

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()

 
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 -- equivalent to calling join()


isFinished

public boolean isFinished()
convenience -- similar to !Thread.isAlive()


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

public void shutdown()


 

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