Class NettyServerHandler<OID_T extends,​GS_VID_T>

  • All Implemented Interfaces:,

    public class NettyServerHandler<OID_T extends,​GS_VID_T>
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface
    • Field Summary

      Modifier and Type Field Description
      static int RESPONSE_BYTES  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void channelRead0​( ctx, WritableRequest msg)
      Please keep in mind that this method will be renamed to messageReceived(ChannelHandlerContext, I) in 5.0.
      void exceptionCaught​( ctx, Throwable cause)  
      long getNumberBytesReceived()  
      void preSuperStep​(MessageStore<OID_T,​,​GS_VID_T> nextIncomingMessages)  
      void resetBytesCounter()  
      • Methods inherited from class

        acceptInboundMessage, channelRead
      • Methods inherited from class

        channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
      • Methods inherited from class

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

        handlerAdded, handlerRemoved
    • Field Detail


        public static int RESPONSE_BYTES
    • Method Detail

      • channelRead0

        protected void channelRead0​( ctx,
                                    WritableRequest msg)
                             throws Exception
        Please keep in mind that this method will be renamed to messageReceived(ChannelHandlerContext, I) in 5.0.

        Is called for each message of type WritableRequest.

        Specified by:
        channelRead0 in class<WritableRequest>
        ctx - the ChannelHandlerContext which this SimpleChannelInboundHandler belongs to
        msg - the message to handle
        Exception - is thrown if an error occurred
      • exceptionCaught

        public void exceptionCaught​( ctx,
                                    Throwable cause)
        Specified by:
        exceptionCaught in interface
        Specified by:
        exceptionCaught in interface
        exceptionCaught in class
      • preSuperStep

        public void preSuperStep​(MessageStore<OID_T,​,​GS_VID_T> nextIncomingMessages)
      • getNumberBytesReceived

        public long getNumberBytesReceived()
      • resetBytesCounter

        public void resetBytesCounter()