Package org.jppf.io

Class ChannelOutputDestination

java.lang.Object
org.jppf.io.ChannelOutputDestination
All Implemented Interfaces:
Closeable, AutoCloseable, IO, OutputDestination
Direct Known Subclasses:
FileOutputDestination

public class ChannelOutputDestination extends Object implements OutputDestination
Output destination backed by a WritableByteChannel.
Author:
Laurent Cohen
  • Field Details

  • Constructor Details

    • ChannelOutputDestination

      public ChannelOutputDestination(WritableByteChannel channel)
      Initialize this output destination with the specified SocketWrapper.
      Parameters:
      channel - the backing SocketWrapper.
  • Method Details

    • write

      public int write(byte[] data, int offset, int len) throws Exception
      Write data to this output destination from an array of bytes.
      Specified by:
      write in interface OutputDestination
      Parameters:
      data - the buffer containing the data to write.
      offset - the position in the buffer where to start reading the data.
      len - the size in bytes of the data to write.
      Returns:
      the number of bytes actually written, or -1 if end of stream was reached.
      Throws:
      Exception - if an IO error occurs.
    • write

      public int write(ByteBuffer data) throws Exception
      Write data to this output destination from a byte buffer.
      Specified by:
      write in interface OutputDestination
      Parameters:
      data - the buffer containing the data to write.
      Returns:
      the number of bytes actually written, or -1 if end of stream was reached.
      Throws:
      Exception - if an IO error occurs.
    • writeInt

      public void writeInt(int value) throws Exception
      Write an int value to this output destination.
      Specified by:
      writeInt in interface OutputDestination
      Parameters:
      value - the value to write.
      Throws:
      Exception - if an IO error occurs.
    • close

      public void close() throws IOException
      This method does nothing.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException - if an IO error occurs.
    • toString

      public String toString()
      Overrides:
      toString in class Object