com.hazelcast.nio.tcp

Class MemberReadHandler

java.lang.Object

com.hazelcast.nio.tcp.MemberReadHandler

All Implemented Interfaces:

ReadHandler

public class MemberReadHandler
extends Object
implements ReadHandler

The ReadHandler for member to member communication. It reads as many packets from the src ByteBuffer as possible, and each of the Packets is send to the PacketDispatcher.

See Also:

PacketDispatcher, MemberWriteHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected TcpIpConnection	connection
protected Packet	packet

Constructor Summary

Constructors

Constructor and Description
MemberReadHandler(TcpIpConnection connection, PacketDispatcher packetDispatcher)

Method Summary

Modifier and Type	Method and Description
protected void	handlePacket(Packet packet)
void	onRead(ByteBuffer src) A callback to indicate that data is available in the ByteBuffer to be processed.

Methods inherited from class java.lang.Object

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

Field Detail

connection

protected final TcpIpConnection connection

packet

protected Packet packet

Constructor Detail

MemberReadHandler

public MemberReadHandler(TcpIpConnection connection,
                         PacketDispatcher packetDispatcher)

Method Detail

onRead

public void onRead(ByteBuffer src)
            throws Exception

Description copied from interface: ReadHandler

A callback to indicate that data is available in the ByteBuffer to be processed.

Specified by:

onRead in interface ReadHandler

Parameters:

src - the ByteBuffer containing the data to read. The ByteBuffer is already in reading mode and when completed, should not be converted to write-mode using clear/compact. That is a task of the SocketReader.

Throws:

Exception - if something fails while reading data from the ByteBuffer or processing the data (e.g. when a Packet fails to get processed). When an exception is thrown, the TcpIpConnection is closed. There is no point continuing with a potentially corrupted stream.

handlePacket

protected void handlePacket(Packet packet)