Class HotRodOperation<T>

    • Method Detail

      • sendHeaderAndRead

        protected void sendHeaderAndRead​(io.netty.channel.Channel channel)
      • sendHeader

        protected void sendHeader​(io.netty.channel.Channel channel)
      • scheduleRead

        protected void scheduleRead​(io.netty.channel.Channel channel)
      • releaseChannel

        public void releaseChannel​(io.netty.channel.Channel channel)
      • channelInactive

        public void channelInactive​(io.netty.channel.Channel channel)
      • exceptionCaught

        public void exceptionCaught​(io.netty.channel.ChannelHandlerContext ctx,
                                    Throwable cause)
      • sendArrayOperation

        protected void sendArrayOperation​(io.netty.channel.Channel channel,
                                          byte[] array)
      • acceptResponse

        public abstract void acceptResponse​(io.netty.buffer.ByteBuf buf,
                                            short status,
                                            HeaderDecoder decoder)
      • scheduleTimeout

        public void scheduleTimeout​(io.netty.channel.EventLoop eventLoop)
      • run

        public void run()
        Specified by:
        run in interface Runnable