com.hazelcast.client.impl.protocol.util

Class ClientMessageDecoder

java.lang.Object

com.hazelcast.internal.networking.nio.ChannelInboundHandlerWithCounters

com.hazelcast.client.impl.protocol.util.ClientMessageDecoder

All Implemented Interfaces:

ChannelInboundHandler

public class ClientMessageDecoder
extends ChannelInboundHandlerWithCounters

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

Field Summary

Fields inherited from class com.hazelcast.internal.networking.nio.ChannelInboundHandlerWithCounters

normalPacketsRead, priorityPacketsRead

Constructor Summary

Constructors

Constructor and Description
ClientMessageDecoder(Connection connection, ClientMessageHandler messageHandler)

Method Summary

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

Methods inherited from class com.hazelcast.internal.networking.nio.ChannelInboundHandlerWithCounters

setNormalPacketsRead, setPriorityPacketsRead

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientMessageDecoder

public ClientMessageDecoder(Connection connection,
                            ClientMessageHandler messageHandler)

Method Detail

onRead

public void onRead(ByteBuffer src)

Description copied from interface: ChannelInboundHandler

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

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.