Class AbstractProxyLogicHandler

    • Method Detail

      • getSession

        protected IoSession getSession()
        Returns:
        the session.
      • writeData

        protected WriteFuture writeData​(IoFilter.NextFilter nextFilter,
                                        IoBuffer data)
        Writes data to the proxy server.
        Parameters:
        nextFilter - the next filter
        data - Data buffer to be written.
        Returns:
        A Future for the write operation
      • isHandshakeComplete

        public boolean isHandshakeComplete()
        Description copied from interface: ProxyLogicHandler
        Tests if handshake process is complete.
        Specified by:
        isHandshakeComplete in interface ProxyLogicHandler
        Returns:
        true if handshaking is complete and data can be sent through the proxy.
      • setHandshakeComplete

        protected final void setHandshakeComplete()
        Signals that the handshake has finished.
      • flushPendingWriteRequests

        protected void flushPendingWriteRequests()
                                          throws Exception
        Send any write requests which were queued whilst waiting for handshaking to complete.
        Throws:
        Exception - If we can't flush the pending write requests
      • enqueueWriteRequest

        public void enqueueWriteRequest​(IoFilter.NextFilter nextFilter,
                                        WriteRequest writeRequest)
        Enqueue a message to be written once handshaking is complete.
        Specified by:
        enqueueWriteRequest in interface ProxyLogicHandler
        Parameters:
        nextFilter - the next filter in filter chain
        writeRequest - the data to be written
      • closeSession

        protected void closeSession​(String message,
                                    Throwable t)
        Closes the session.
        Parameters:
        message - the error message
        t - the exception which caused the session closing
      • closeSession

        protected void closeSession​(String message)
        Closes the session.
        Parameters:
        message - the error message