com.hazelcast.client.connection.nio

Class ClientWriteHandler

java.lang.Object

com.hazelcast.client.connection.nio.AbstractClientSelectionHandler

com.hazelcast.client.connection.nio.ClientWriteHandler

All Implemented Interfaces:

SelectionHandler, Runnable

public class ClientWriteHandler
extends AbstractClientSelectionHandler
implements Runnable

ClientReadHandler gets called by an IO-thread when there is space available to write to. It then writes some of its enqueued data to the socket from a bytebuffer.

Field Summary

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

connection, connectionManager, eventCount, logger, socketChannel

Constructor Summary

Constructors

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

Method Summary

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

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

onFailure, register

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientWriteHandler

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

Method Detail

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.

Specified by:

handle in interface SelectionHandler

Throws:

Exception

enqueue

public void enqueue(OutboundFrame frame)

run

public void run()

Specified by:

run in interface Runnable

shutdown

public void shutdown()

Overrides:

shutdown in class AbstractClientSelectionHandler