com.hazelcast.client.impl.protocol.util

Class ClientMessageReadHandler

java.lang.Object

com.hazelcast.client.impl.protocol.util.ClientMessageReadHandler

All Implemented Interfaces:

ReadHandler

public class ClientMessageReadHandler
extends Object
implements ReadHandler

Builds ClientMessages from byte chunks. Fragmented messages are merged into single messages before processed.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ClientMessageReadHandler.MessageHandler Implementers will be responsible to delegate the constructed message

Constructor Summary

Constructors

Constructor and Description
ClientMessageReadHandler(SwCounter messageCounter, ClientMessageReadHandler.MessageHandler messageHandler)

Method Summary

Modifier and Type	Method and Description
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

Constructor Detail

ClientMessageReadHandler

public ClientMessageReadHandler(SwCounter messageCounter,
                                ClientMessageReadHandler.MessageHandler messageHandler)

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.