Class 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>
    • Nested Class Summary

      • Nested classes/interfaces inherited from class io.netty.handler.codec.ByteToMessageDecoder

        io.netty.handler.codec.ByteToMessageDecoder.Cumulator
      • Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

        io.netty.channel.ChannelHandler.Sharable
    • Field Summary

      Fields 
      Modifier and Type Field Description
      static String NAME  
      • Fields inherited from class io.netty.handler.codec.ByteToMessageDecoder

        COMPOSITE_CUMULATOR, MERGE_CUMULATOR
    • Method Detail

      • isSharable

        public boolean isSharable()
        Overrides:
        isSharable in class io.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 class io.netty.handler.codec.ByteToMessageDecoder
        Throws:
        Exception
      • exceptionCaught

        public void exceptionCaught​(io.netty.channel.ChannelHandlerContext ctx,
                                    Throwable cause)
        Specified by:
        exceptionCaught in interface io.netty.channel.ChannelHandler
        Specified by:
        exceptionCaught in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter
      • channelInactive

        public void channelInactive​(io.netty.channel.ChannelHandlerContext ctx)
        Specified by:
        channelInactive in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelInactive in class HintedReplayingDecoder<org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.State>
      • userEventTriggered

        public void userEventTriggered​(io.netty.channel.ChannelHandlerContext ctx,
                                       Object evt)
                                throws Exception
        Specified by:
        userEventTriggered in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        userEventTriggered in class io.netty.handler.codec.ByteToMessageDecoder
        Throws:
        Exception
      • checkpoint

        public void checkpoint()
        Stores the internal cumulative buffer's reader position. Checkpoint is exposed for implementations of HotRodOperation
        Overrides:
        checkpoint in class HintedReplayingDecoder<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)