Class AsyncServer

    • Method Detail

      • listen

        public java.util.concurrent.Future<ListenerEndpoint> listen​(java.net.SocketAddress address,
                                                                    java.lang.Object attachment,
                                                                    FutureCallback<ListenerEndpoint> callback)
        Description copied from interface: ConnectionAcceptor
        Opens a new listener endpoint with the given socket address. Once the endpoint is fully initialized it starts accepting incoming connections and propagates I/O activity notifications to the I/O event dispatcher.
        Specified by:
        listen in interface ConnectionAcceptor
        Parameters:
        address - the socket address to listen on.
        attachment - the attachment object.
        callback - the result callback.
        Returns:
        listener endpoint.
        Since:
        5.1
      • listen

        public java.util.concurrent.Future<ListenerEndpoint> listen​(java.net.SocketAddress address,
                                                                    FutureCallback<ListenerEndpoint> callback)
        Description copied from interface: ConnectionAcceptor
        Opens a new listener endpoint with the given socket address. Once the endpoint is fully initialized it starts accepting incoming connections and propagates I/O activity notifications to the I/O event dispatcher.
        Specified by:
        listen in interface ConnectionAcceptor
        Parameters:
        address - the socket address to listen on.
        callback - the result callback.
        Returns:
        listener endpoint.
      • listen

        public java.util.concurrent.Future<ListenerEndpoint> listen​(java.net.SocketAddress address)
      • pause

        public void pause()
                   throws java.io.IOException
        Description copied from interface: ConnectionAcceptor
        Suspends the I/O reactor preventing it from accepting new connections on all active endpoints.
        Specified by:
        pause in interface ConnectionAcceptor
        Throws:
        java.io.IOException - in case of an I/O error.
      • resume

        public void resume()
                    throws java.io.IOException
        Description copied from interface: ConnectionAcceptor
        Resumes the I/O reactor restoring its ability to accept incoming connections on all active endpoints.
        Specified by:
        resume in interface ConnectionAcceptor
        Throws:
        java.io.IOException - in case of an I/O error.
      • getStatus

        public IOReactorStatus getStatus()
        Description copied from interface: IOReactor
        Returns the current status of the reactor.
        Specified by:
        getStatus in interface IOReactor
        Returns:
        reactor status.
      • initiateShutdown

        public void initiateShutdown()
        Description copied from interface: IOReactor
        Initiates shutdown of the reactor without blocking. The reactor is expected to terminate all active connections, to shut down itself and to release system resources it currently holds
        Specified by:
        initiateShutdown in interface IOReactor
      • awaitShutdown

        public void awaitShutdown​(TimeValue waitTime)
                           throws java.lang.InterruptedException
        Description copied from interface: IOReactor
        Blocks for the given period of time in milliseconds awaiting the completion of the reactor shutdown.
        Specified by:
        awaitShutdown in interface IOReactor
        Parameters:
        waitTime - wait time.
        Throws:
        java.lang.InterruptedException
      • close

        public void close​(CloseMode closeMode)
        Description copied from interface: IOReactor
        Shuts down the I/O reactor either gracefully or immediately. During graceful shutdown individual I/O sessions should be informed about imminent termination and be given a grace period to complete the ongoing I/O sessions. During immediate shutdown all ongoing I/O sessions get aborted immediately.
        Specified by:
        close in interface IOReactor
        Specified by:
        close in interface ModalCloseable
        Parameters:
        closeMode - How to close the receiver.
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException