org.globus.io.gass.server
Class JobOutputStream

java.lang.Object
  extended by java.io.OutputStream
      extended by org.globus.io.gass.server.JobOutputStream
All Implemented Interfaces:
java.io.Closeable, java.io.Flushable

public class JobOutputStream
extends java.io.OutputStream

This is a small class that allows to redirect a job's output to a custom job output listener. That is, a listener that presents/displays the job output in a specific way. For example, this class can be used to redirect a job's output to a window.

This class is specificaly designed for jobs that generate textual output. Binary data might not be handled correctly.


Field Summary
protected  JobOutputListener listener
           
 
Constructor Summary
JobOutputStream(JobOutputListener jobListener)
          Creates a job output stream with a specific job output listener to which the job output will be redirected to.
 
Method Summary
 void close()
          Notifies the job output listener that no more output will be produced.
 void write(byte[] b, int off, int len)
          Converts the byte array to a string and forwards it to the job output listener.
 void write(int b)
          Converts the int to a string and forwards it to the job output listener.
 
Methods inherited from class java.io.OutputStream
flush, write
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

listener

protected JobOutputListener listener
Constructor Detail

JobOutputStream

public JobOutputStream(JobOutputListener jobListener)
Creates a job output stream with a specific job output listener to which the job output will be redirected to.

Parameters:
jobListener - an instance of the job output listener. Cannot be null.
Method Detail

write

public void write(byte[] b,
                  int off,
                  int len)
           throws java.io.IOException
Converts the byte array to a string and forwards it to the job output listener.
Called by the GassServer.

Overrides:
write in class java.io.OutputStream
Throws:
java.io.IOException

write

public void write(int b)
           throws java.io.IOException
Converts the int to a string and forwards it to the job output listener.
Called by the GassServer.

Specified by:
write in class java.io.OutputStream
Throws:
java.io.IOException

close

public void close()
           throws java.io.IOException
Notifies the job output listener that no more output will be produced.
Called by the GassServer.

Specified by:
close in interface java.io.Closeable
Overrides:
close in class java.io.OutputStream
Throws:
java.io.IOException


Copyright © 2013. All Rights Reserved.