Class NettyServerCnxn

  • All Implemented Interfaces:
    Watcher

    public class NettyServerCnxn
    extends ServerCnxn
    • Method Detail

      • close

        public void close()
      • getSessionTimeout

        public int getSessionTimeout()
      • sendResponse

        public void sendResponse​(org.apache.zookeeper.proto.ReplyHeader h,
                                 org.apache.jute.Record r,
                                 java.lang.String tag)
                          throws java.io.IOException
        Overrides:
        sendResponse in class ServerCnxn
        Throws:
        java.io.IOException
      • setSessionId

        public void setSessionId​(long sessionId)
      • sendBuffer

        public void sendBuffer​(java.nio.ByteBuffer sendBuffer)
      • disableRecv

        public void disableRecv()
        Note that both disableRecv() and disableRecvNoWait() are asynchronous in the netty implementation.
      • enableRecv

        public void enableRecv()
      • setSessionTimeout

        public void setSessionTimeout​(int sessionTimeout)
      • sendCloseSession

        public void sendCloseSession()
        Send close connection packet to the client.