com.hazelcast.nio.tcp

Class NewClientReadHandler

java.lang.Object

com.hazelcast.nio.tcp.NewClientReadHandler

All Implemented Interfaces:

ClientMessageBuilder.MessageHandler, ReadHandler

public class NewClientReadHandler
extends Object
implements ReadHandler, ClientMessageBuilder.MessageHandler

A ReadHandler for the new-client. It passes the ByteBuffer to the ClientMessageBuilder. For each constructed ClientMessage, the handleMessage(ClientMessage) is called; which passes the message to the IOService.handleClientMessage(ClientMessage, Connection). Probably the design can be simplified if the IOService would expose a method getMessageHandler; so we don't need to let the NewClientReadHandler act like the MessageHandler, but directly send to the right data-structure.

See Also:

NewClientWriteHandler

Constructor Summary

Constructors

Constructor and Description
NewClientReadHandler(Connection connection, IOService ioService)

Method Summary

Methods

Modifier and Type	Method and Description
void	handleMessage(ClientMessage message) Received message to be processed
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

NewClientReadHandler

public NewClientReadHandler(Connection connection,
                    IOService ioService)
                     throws IOException

Throws:

IOException

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.

handleMessage

public void handleMessage(ClientMessage message)

Description copied from interface: ClientMessageBuilder.MessageHandler

Received message to be processed

Specified by:

handleMessage in interface ClientMessageBuilder.MessageHandler

Parameters:

message - the ClientMessage