Class AbstractNioMessageChannel

    • Method Detail

      • doBeginRead

        protected void doBeginRead()
                            throws java.lang.Exception
        Description copied from class: AbstractChannel
        Schedule a read operation.
        Overrides:
        doBeginRead in class AbstractNioChannel
        Throws:
        java.lang.Exception
      • continueOnWriteError

        protected boolean continueOnWriteError()
        Returns true if we should continue the write loop on a write error.
      • closeOnReadError

        protected boolean closeOnReadError​(java.lang.Throwable cause)
      • doReadMessages

        protected abstract int doReadMessages​(java.util.List<java.lang.Object> buf)
                                       throws java.lang.Exception
        Read messages into the given array and return the amount which was read.
        Throws:
        java.lang.Exception
      • doWriteMessage

        protected abstract boolean doWriteMessage​(java.lang.Object msg,
                                                  ChannelOutboundBuffer in)
                                           throws java.lang.Exception
        Write a message to the underlying Channel.
        Returns:
        true if and only if the message has been written
        Throws:
        java.lang.Exception