Package org.jppf.server.nio.nodeserver.async

Class AsyncNodeMessageReader

java.lang.Object

org.jppf.nio.NioMessageReader<AsyncNodeContext>

org.jppf.server.nio.nodeserver.async.AsyncNodeMessageReader

public class AsyncNodeMessageReader
extends org.jppf.nio.NioMessageReader<AsyncNodeContext>

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
AsyncNodeMessageReader(AsyncNodeNioServer server)	Initialize this message reader.

Method Summary

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

Methods inherited from class org.jppf.nio.NioMessageReader

read

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncNodeMessageReader

public AsyncNodeMessageReader(AsyncNodeNioServer server)

Initialize this message reader.

Parameters:

server - the nio server.

Method Details

createMessageHandler

protected org.jppf.nio.NioMessageReader.MessageHandler<AsyncNodeContext> createMessageHandler()

Specified by:

createMessageHandler in class org.jppf.nio.NioMessageReader<AsyncNodeContext>

getExecutor

protected ExecutorService getExecutor()

Overrides:

getExecutor in class org.jppf.nio.NioMessageReader<AsyncNodeContext>