Package org.jppf.server.nio.client

Class ClientMessage

java.lang.Object
org.jppf.nio.AbstractNioMessageBase
org.jppf.nio.AbstractNioMessage
org.jppf.server.nio.AbstractTaskBundleMessage
org.jppf.server.nio.client.ClientMessage
All Implemented Interfaces:
org.jppf.nio.NioMessage
public class ClientMessage 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
    ClientMessage(org.jppf.nio.NioContext context, ServerTaskBundleClient clientBundle)
    Initialize this nio message with the specified context.

  • 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.
    ServerTaskBundleClient
    getClientBundle()
     
    protected boolean
    readNextObject()
     
    String
    toString()
     

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

    getBundle, setBundle

    Methods inherited from class org.jppf.nio.AbstractNioMessage

    addLocation, getLocations, read, 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

    • ClientMessage

      public ClientMessage(org.jppf.nio.NioContext context, ServerTaskBundleClient clientBundle)
      Initialize this nio message with the specified context.
      Parameters:
      context - the context to read from or write to.
      clientBundle - the actual client task bundle from which this message is created.

  • 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

    • getClientBundle

      public ServerTaskBundleClient getClientBundle()
      Returns:
      the actual client task bundle from which this message is created

    • readNextObject

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