Class NettyServerCnxn

  • All Implemented Interfaces:
    Watcher

    public class NettyServerCnxn
    extends ServerCnxn
    • Method Detail

      • close

        public void close()
      • getSessionId

        public long getSessionId()
      • getSessionTimeout

        public int getSessionTimeout()
      • sendResponse

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

        public void setSessionId​(long sessionId)
      • enableRecv

        public void enableRecv()
      • sendBuffer

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

        public java.net.InetAddress getSocketAddress()
        Description copied from class: ServerCnxn
        Wrapper method to return the socket address
        Specified by:
        getSocketAddress in class ServerCnxn
      • receiveMessage

        public void receiveMessage​(ChannelBuffer message)
      • disableRecv

        public void disableRecv()
      • setSessionTimeout

        public void setSessionTimeout​(int sessionTimeout)
      • sendCloseSession

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