Class KeyValueMessageHandler

  • All Implemented Interfaces:,,

    public class KeyValueMessageHandler
    This handler is responsible for writing KV requests and completing their associated responses once they arrive.
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void channelActive​( ctx)
      Actions to be performed when the channel becomes active.
      void channelInactive​( ctx)  
      void channelRead​( ctx, Object msg)  
      void write​( ctx, Object msg, promise)  
      • Methods inherited from class

        bind, close, connect, deregister, disconnect, flush, read
      • Methods inherited from class

        channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
      • Methods inherited from class

        ensureNotSharable, handlerAdded, handlerRemoved, isSharable
      • Methods inherited from interface

        handlerAdded, handlerRemoved
    • Method Detail

      • channelActive

        public void channelActive​( ctx)
        Actions to be performed when the channel becomes active.

        Since the opaque is incremented in the handler below during bootstrap but now is only modified in this handler, cache the reference since the attribute lookup is more costly.

        Specified by:
        channelActive in interface
        channelActive in class
        ctx - the channel context.
      • write

        public void write​( ctx,
                          Object msg,
        Specified by:
        write in interface
        write in class
      • channelRead

        public void channelRead​( ctx,
                                Object msg)
        Specified by:
        channelRead in interface
        channelRead in class
      • channelInactive

        public void channelInactive​( ctx)
        Specified by:
        channelInactive in interface
        channelInactive in class