Class DefaultReadFuture

    • Constructor Detail

      • DefaultReadFuture

        public DefaultReadFuture​(IoSession session)
        Creates a new instance.
        Parameters:
        session - The associated session
    • Method Detail

      • getMessage

        public Object getMessage()
        Get the read message.
        Specified by:
        getMessage in interface ReadFuture
        Returns:
        the received message. It returns null if this future is not ready or the associated IoSession has been closed.
      • isRead

        public boolean isRead()
        Specified by:
        isRead in interface ReadFuture
        Returns:
        true if a message was received successfully.
      • isClosed

        public boolean isClosed()
        Specified by:
        isClosed in interface ReadFuture
        Returns:
        true if the IoSession associated with this future has been closed.
      • getException

        public Throwable getException()
        Specified by:
        getException in interface ReadFuture
        Returns:
        the cause of the read failure if and only if the read operation has failed due to an Exception. Otherwise, null is returned.
      • setClosed

        public void setClosed()
        Sets the associated IoSession is closed. This method is invoked by MINA internally. Please do not call this method directly.
        Specified by:
        setClosed in interface ReadFuture
      • setRead

        public void setRead​(Object message)
        Sets the message is written, and notifies all threads waiting for this future. This method is invoked by MINA internally. Please do not call this method directly.
        Specified by:
        setRead in interface ReadFuture
        Parameters:
        message - The received message to store in this future
      • setException

        public void setException​(Throwable exception)
        Sets the cause of the read failure, and notifies all threads waiting for this future. This method is invoked by MINA internally. Please do not call this method directly.
        Specified by:
        setException in interface ReadFuture
        Parameters:
        exception - The exception to store in the Future instance