Package org.jppf.server.nio.classloader.node

Class AsyncNodeClassMessageReader

java.lang.Object
org.jppf.nio.NioMessageReader<AsyncNodeClassContext>
org.jppf.server.nio.classloader.node.AsyncNodeClassMessageReader
public class AsyncNodeClassMessageReader extends org.jppf.nio.NioMessageReader<AsyncNodeClassContext>
Reads from the channel until no more data is available. Each fully read message is handed off to a global thread pool for deserialization and processing.
Author:
Laurent Cohen

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.jppf.nio.NioMessageReader

    org.jppf.nio.NioMessageReader.MessageHandler<C extends org.jppf.nio.AbstractNioContext>

  • Field Summary

    Fields inherited from class org.jppf.nio.NioMessageReader

    messageHandler, server

  • Constructor Summary

    Constructors
    Constructor
    Description
    AsyncNodeClassMessageReader(AsyncNodeClassNioServer server)
    Initialize this message reader.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.jppf.nio.NioMessageReader.MessageHandler<AsyncNodeClassContext>
    createMessageHandler()
     

    Methods inherited from class org.jppf.nio.NioMessageReader

    getExecutor, read

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AsyncNodeClassMessageReader

      public AsyncNodeClassMessageReader(AsyncNodeClassNioServer server)
      Initialize this message reader.
      Parameters:
      server - the nio server.

  • Method Details

    • createMessageHandler

      protected org.jppf.nio.NioMessageReader.MessageHandler<AsyncNodeClassContext> createMessageHandler()
      Specified by:
      createMessageHandler in class org.jppf.nio.NioMessageReader<AsyncNodeClassContext>