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

Class AsyncNodeMessageWriter

java.lang.Object

org.jppf.nio.NioMessageWriter<AsyncNodeContext>

org.jppf.server.nio.nodeserver.async.AsyncNodeMessageWriter

public class AsyncNodeMessageWriter
extends org.jppf.nio.NioMessageWriter<AsyncNodeContext>

Writes all messages in the channel's context queue, if any, or keeps writing the current message until the socket send buffer is full.

Author:

Laurent Cohen

Field Summary

Fields inherited from class org.jppf.nio.NioMessageWriter

server

Constructor Summary

Constructors

Constructor	Description
AsyncNodeMessageWriter(org.jppf.nio.StatelessNioServer<AsyncNodeContext> server)	Initialize this message writer.

Method Summary

Modifier and Type	Method	Description
protected void	postWrite(AsyncNodeContext context, org.jppf.nio.NioMessage data)
protected void	preWrite(AsyncNodeContext context, org.jppf.nio.NioMessage data)

Methods inherited from class org.jppf.nio.NioMessageWriter

doWrite, write

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncNodeMessageWriter

public AsyncNodeMessageWriter(org.jppf.nio.StatelessNioServer<AsyncNodeContext> server)

Initialize this message writer.

Parameters:

server - the nio server.

Method Details

preWrite

protected void preWrite(AsyncNodeContext context,
 org.jppf.nio.NioMessage data)
                 throws Exception

Overrides:

preWrite in class org.jppf.nio.NioMessageWriter<AsyncNodeContext>

Throws:

Exception

postWrite

protected void postWrite(AsyncNodeContext context,
 org.jppf.nio.NioMessage data)
                  throws Exception

Specified by:

postWrite in class org.jppf.nio.NioMessageWriter<AsyncNodeContext>

Throws:

Exception