Class PacketProcessorBaseV3

    • Constructor Summary

      Constructors 
      Constructor Description
      PacketProcessorBaseV3​(org.apache.bookkeeper.proto.BookkeeperProtocol.Request request, io.netty.channel.Channel channel, BookieRequestProcessor requestProcessor)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader()
      Build a header with protocol version 3 and the operation type same as what was in the request.
      protected boolean isVersionCompatible()  
      protected void sendResponse​(org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode code, java.lang.Object response, OpStatsLogger statsLogger)  
      java.lang.String toString()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Field Detail

      • request

        final org.apache.bookkeeper.proto.BookkeeperProtocol.Request request
      • channel

        final io.netty.channel.Channel channel
      • enqueueNanos

        final long enqueueNanos
    • Constructor Detail

      • PacketProcessorBaseV3

        public PacketProcessorBaseV3​(org.apache.bookkeeper.proto.BookkeeperProtocol.Request request,
                                     io.netty.channel.Channel channel,
                                     BookieRequestProcessor requestProcessor)
    • Method Detail

      • sendResponse

        protected void sendResponse​(org.apache.bookkeeper.proto.BookkeeperProtocol.StatusCode code,
                                    java.lang.Object response,
                                    OpStatsLogger statsLogger)
      • isVersionCompatible

        protected boolean isVersionCompatible()
      • getHeader

        protected org.apache.bookkeeper.proto.BookkeeperProtocol.BKPacketHeader getHeader()
        Build a header with protocol version 3 and the operation type same as what was in the request.
        Returns:
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object