Package org.jppf.server.nio.nodeserver

Class RemoteNodeMessage

java.lang.Object
org.jppf.nio.AbstractNioMessageBase
org.jppf.nio.AbstractNioMessage
org.jppf.server.nio.AbstractTaskBundleMessage
org.jppf.server.nio.nodeserver.RemoteNodeMessage
All Implemented Interfaces:
org.jppf.nio.NioMessage
public class RemoteNodeMessage extends AbstractTaskBundleMessage
Representation of a message sent or received by a remote 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
    RemoteNodeMessage(BaseNodeContext context)
    Initialize this nio message with the specified sll flag.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    afterFirstRead()
    Actions to take after the first object in the message has been fully read.
    protected void
    beforeFirstWrite()
    Actions to take before the first object in the message is written.
    String
    toString()
     

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

    getBundle, setBundle

    Methods inherited from class org.jppf.nio.AbstractNioMessage

    addLocation, getLocations, read, readNextObject, write, writeNextObject

    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

    • RemoteNodeMessage

      public RemoteNodeMessage(BaseNodeContext context)
      Initialize this nio message with the specified sll flag.
      Parameters:
      context - the channel to read from or write to.

  • Method Details

    • afterFirstRead

      protected void afterFirstRead() throws Exception
      Actions to take after the first object in the message has been fully read.
      Overrides:
      afterFirstRead in class org.jppf.nio.AbstractNioMessage
      Throws:
      Exception - if an IO error occurs.

    • beforeFirstWrite

      protected void beforeFirstWrite() throws Exception
      Actions to take before the first object in the message is written.
      Overrides:
      beforeFirstWrite in class org.jppf.nio.AbstractNioMessage
      Throws:
      Exception - if an IO error occurs.

    • toString

      public String toString()
      Overrides:
      toString in class AbstractTaskBundleMessage