Package org.jppf.server.nio.nodeserver

Class LocalNodeMessage

java.lang.Object
org.jppf.nio.AbstractNioMessageBase
org.jppf.nio.AbstractNioMessage
org.jppf.server.nio.AbstractTaskBundleMessage
org.jppf.server.nio.nodeserver.LocalNodeMessage
All Implemented Interfaces:
org.jppf.nio.NioMessage
public class LocalNodeMessage extends AbstractTaskBundleMessage
Node message implementation for an in-VM node.
Author:
Laurent Cohen

  • Field Summary

    Fields inherited from class org.jppf.server.nio.AbstractTaskBundleMessage

    bundle

    Fields inherited from class org.jppf.nio.AbstractNioMessage

    locations, nbObjects, position

    Fields inherited from class org.jppf.nio.AbstractNioMessageBase

    channel, channelReadCount, channelWriteCount, count, currentDataLocation, currentLength, currentLengthObject, currentObject, lengthBuf, resetCurrentLength, ssl, sslHandler, sslHandlerReadCount, sslHandlerWriteCount

    Fields inherited from interface org.jppf.nio.NioMessage

    READ, WRITE

  • Constructor Summary

    Constructors
    Constructor
    Description
    LocalNodeMessage(BaseNodeContext context)
    Build this nio message.

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    read()
     
    protected boolean
    readNextObject()
     
    boolean
    write()
     
    protected boolean
    writeNextObject()
     

    Methods inherited from class org.jppf.server.nio.AbstractTaskBundleMessage

    getBundle, setBundle, toString

    Methods inherited from class org.jppf.nio.AbstractNioMessage

    addLocation, afterFirstRead, beforeFirstWrite, getLocations

    Methods inherited from class org.jppf.nio.AbstractNioMessageBase

    getChannelReadCount, getChannelWriteCount, getCurrentDataLocation, isSSL, updateCounts

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • LocalNodeMessage

      public LocalNodeMessage(BaseNodeContext context)
      Build this nio message.
      Parameters:
      context - the channel to read from or write to.

  • Method Details

    • read

      public boolean read() throws Exception
      Specified by:
      read in interface org.jppf.nio.NioMessage
      Overrides:
      read in class org.jppf.nio.AbstractNioMessage
      Throws:
      Exception

    • readNextObject

      protected boolean readNextObject() throws Exception
      Overrides:
      readNextObject in class org.jppf.nio.AbstractNioMessage
      Throws:
      Exception

    • write

      public boolean write() throws Exception
      Specified by:
      write in interface org.jppf.nio.NioMessage
      Overrides:
      write in class org.jppf.nio.AbstractNioMessage
      Throws:
      Exception

    • writeNextObject

      protected boolean writeNextObject() throws Exception
      Overrides:
      writeNextObject in class org.jppf.nio.AbstractNioMessage
      Throws:
      Exception