com.hazelcast.client.connection.nio

Class ClientReadHandler

java.lang.Object

com.hazelcast.client.connection.nio.AbstractClientSelectionHandler

com.hazelcast.client.connection.nio.ClientReadHandler

All Implemented Interfaces:

SelectionHandler, Runnable

public class ClientReadHandler
extends AbstractClientSelectionHandler

ClientReadHandler gets called by an IO-thread when there is data available to read. It then reads out the data from the socket into a bytebuffer and hands it over to the ClientMessageBuilder to get processed.

Field Summary

Fields inherited from class com.hazelcast.client.connection.nio.AbstractClientSelectionHandler

connection, connectionManager, eventCount, logger, socketChannel

Constructor Summary

Constructors

Constructor and Description
ClientReadHandler(ClientConnection connection, NonBlockingIOThread ioThread, int bufferSize, boolean direct, LoggingService loggingService)

Method Summary

Methods

Modifier and Type	Method and Description
void	handle() Called when there are bytes available for reading, or space available to write.
void	run()

Methods inherited from class com.hazelcast.client.connection.nio.AbstractClientSelectionHandler

onFailure, register, shutdown

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientReadHandler

public ClientReadHandler(ClientConnection connection,
                 NonBlockingIOThread ioThread,
                 int bufferSize,
                 boolean direct,
                 LoggingService loggingService)

Method Detail

run

public void run()

handle

public void handle()
            throws Exception

Description copied from interface: SelectionHandler

Called when there are bytes available for reading, or space available to write. Any exception that leads to a termination of the connection like an IOException should not be handled in the handle method but should be propagated. The reason behind this is that the handle logic already is complicated enough and by pulling it out the flow will be easier to understand.

Throws:

Exception