public class ClientMessageDecoder extends InboundHandlerWithCounters<ByteBuffer,Consumer<ClientMessage>>
ClientMessage
s from byte chunks.
Fragmented messages are merged into single messages before processed.normalPacketsRead, priorityPacketsRead
channel, dst, src
Constructor and Description |
---|
ClientMessageDecoder(Connection connection,
Consumer<ClientMessage> dst) |
Modifier and Type | Method and Description |
---|---|
void |
handlerAdded()
Gets called when this ChannelHandler is added to the pipeline.
|
HandlerStatus |
onRead()
A callback to indicate that data is available in the src to be
processed.
|
setNormalPacketsRead, setPriorityPacketsRead
initSrcBuffer, initSrcBuffer
dst, dst, interceptError, setChannel, src, src
public ClientMessageDecoder(Connection connection, Consumer<ClientMessage> dst)
public void handlerAdded()
ChannelHandler
handlerAdded
in class ChannelHandler<InboundHandler,ByteBuffer,Consumer<ClientMessage>>
public HandlerStatus onRead()
InboundHandler
onRead
in class InboundHandler<ByteBuffer,Consumer<ClientMessage>>
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.