org.jppf.server.nio.nodeserver
Class LocalNodeMessage

java.lang.Object
  org.jppf.server.nio.nodeserver.AbstractNodeMessage
      org.jppf.server.nio.nodeserver.LocalNodeMessage

public class LocalNodeMessage
extends AbstractNodeMessage

Node message implementation for an in-VM node.

Author:

Laurent Cohen

Field Summary

Fields inherited from class org.jppf.server.nio.nodeserver.AbstractNodeMessage

bundle, count, length, locations, nbObjects, position

Constructor Summary

LocalNodeMessage()

Method Summary

boolean	read(ChannelWrapper<?> wrapper) Read data from the channel.
protected boolean	readNextObject(ChannelWrapper<?> wrapper) Read the next serializable object from the specified channel.
boolean	write(ChannelWrapper<?> wrapper) Read data from the channel.
protected boolean	writeNextObject(ChannelWrapper<?> wrapper) Write the next object to the specified channel.

Methods inherited from class org.jppf.server.nio.nodeserver.AbstractNodeMessage

addLocation, getBundle, getLength, getLocations, setBundle, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalNodeMessage

public LocalNodeMessage()

Method Detail

read

public boolean read(ChannelWrapper<?> wrapper)
             throws Exception

Read data from the channel.

Overrides:

read in class AbstractNodeMessage

Parameters:

wrapper - the channel to read from.

Returns:

true if the data has been completely read from the channel, false otherwise.

Throws:

Exception - if an IO error occurs.

readNextObject

protected boolean readNextObject(ChannelWrapper<?> wrapper)
                          throws Exception

Read the next serializable object from the specified channel.

Specified by:

readNextObject in class AbstractNodeMessage

Parameters:

wrapper - the channel to read from.

Returns:

true if the object has been completely read from the channel, false otherwise.

Throws:

Exception - if an IO error occurs.

write

public boolean write(ChannelWrapper<?> wrapper)
              throws Exception

Read data from the channel.

Overrides:

write in class AbstractNodeMessage

Parameters:

wrapper - the channel to write to.

Returns:

true if the data has been completely written the channel, false otherwise.

Throws:

Exception - if an IO error occurs.

writeNextObject

protected boolean writeNextObject(ChannelWrapper<?> wrapper)
                           throws Exception

Write the next object to the specified channel.

Specified by:

writeNextObject in class AbstractNodeMessage

Parameters:

wrapper - the channel to write to.

Returns:

true if the object has been completely written the channel, false otherwise.

Throws:

Exception - if an IO error occurs.