Class HeaderDecoder
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.handler.codec.ByteToMessageDecoder
-
- org.infinispan.client.hotrod.impl.transport.netty.HintedReplayingDecoder<org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.State>
-
- org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder
-
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
public class HeaderDecoder extends HintedReplayingDecoder<org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.State>
-
-
Constructor Summary
Constructors Constructor Description HeaderDecoder(Codec codec, ChannelFactory channelFactory, Configuration configuration, ClientListenerNotifier listenerNotifier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addListener(byte[] listenerId)
CompletableFuture<Void>
allCompleteFuture()
void
channelInactive(io.netty.channel.ChannelHandlerContext ctx)
void
checkpoint()
Stores the internal cumulative buffer's reader position.protected void
decode(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf in, List<Object> out)
void
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
boolean
isSharable()
int
registeredOperations()
void
registerOperation(io.netty.channel.Channel channel, HotRodOperation<?> operation)
void
removeListener(byte[] listenerId)
void
userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)
-
Methods inherited from class org.infinispan.client.hotrod.impl.transport.netty.HintedReplayingDecoder
callDecode, checkpoint, state, state
-
Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder
actualReadableBytes, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode
-
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged
-
-
-
-
Field Detail
-
NAME
public static final String NAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
HeaderDecoder
public HeaderDecoder(Codec codec, ChannelFactory channelFactory, Configuration configuration, ClientListenerNotifier listenerNotifier)
-
-
Method Detail
-
isSharable
public boolean isSharable()
- Overrides:
isSharable
in classio.netty.channel.ChannelHandlerAdapter
-
registerOperation
public void registerOperation(io.netty.channel.Channel channel, HotRodOperation<?> operation)
-
decode
protected void decode(io.netty.channel.ChannelHandlerContext ctx, io.netty.buffer.ByteBuf in, List<Object> out) throws Exception
- Specified by:
decode
in classio.netty.handler.codec.ByteToMessageDecoder
- Throws:
Exception
-
exceptionCaught
public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelHandler
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
exceptionCaught
in classio.netty.channel.ChannelInboundHandlerAdapter
-
channelInactive
public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)
- Specified by:
channelInactive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelInactive
in classHintedReplayingDecoder<org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.State>
-
allCompleteFuture
public CompletableFuture<Void> allCompleteFuture()
-
userEventTriggered
public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt) throws Exception
- Specified by:
userEventTriggered
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
userEventTriggered
in classio.netty.handler.codec.ByteToMessageDecoder
- Throws:
Exception
-
checkpoint
public void checkpoint()
Stores the internal cumulative buffer's reader position. Checkpoint is exposed for implementations ofHotRodOperation
- Overrides:
checkpoint
in classHintedReplayingDecoder<org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.State>
-
registeredOperations
public int registeredOperations()
-
addListener
public void addListener(byte[] listenerId)
-
removeListener
public void removeListener(byte[] listenerId)
-
-