Class QuicServerConnector

    • Method Detail

      • getInputBufferSize

        public int getInputBufferSize()
      • setInputBufferSize

        public void setInputBufferSize​(int inputBufferSize)
      • getOutputBufferSize

        public int getOutputBufferSize()
      • setOutputBufferSize

        public void setOutputBufferSize​(int outputBufferSize)
      • isUseInputDirectByteBuffers

        public boolean isUseInputDirectByteBuffers()
      • setUseInputDirectByteBuffers

        public void setUseInputDirectByteBuffers​(boolean useInputDirectByteBuffers)
      • isUseOutputDirectByteBuffers

        public boolean isUseOutputDirectByteBuffers()
      • setUseOutputDirectByteBuffers

        public void setUseOutputDirectByteBuffers​(boolean useOutputDirectByteBuffers)
      • isOpen

        public boolean isOpen()
        Description copied from interface: NetworkConnector
        A Connector may be opened and not started (to reserve a port) or closed and running (to allow graceful shutdown of existing connections)
        Returns:
        True if the connector is Open.
      • doStart

        protected void doStart()
                        throws java.lang.Exception
        Description copied from class: ContainerLifeCycle
        Starts the managed lifecycle beans in the order they were added.
        Overrides:
        doStart in class AbstractNetworkConnector
        Throws:
        AbstractLifeCycle.StopException - If thrown, the lifecycle will immediately be stopped.
        java.lang.Exception - If there was a problem starting. Will cause a transition to FAILED state
      • openDatagramChannel

        protected java.nio.channels.DatagramChannel openDatagramChannel()
                                                                 throws java.io.IOException
        Throws:
        java.io.IOException
      • setIdleTimeout

        public void setIdleTimeout​(long idleTimeout)
        Description copied from class: AbstractConnector

        Sets the maximum Idle time for a connection, which roughly translates to the Socket.setSoTimeout(int) call, although with NIO implementations other mechanisms may be used to implement the timeout.

        The max idle time is applied:

        • When waiting for a new message to be received on a connection
        • When waiting for a new message to be sent on a connection

        This value is interpreted as the maximum time between some progress being made on the connection. So if a single byte is read or written, then the timeout is reset.

        Overrides:
        setIdleTimeout in class AbstractConnector
        Parameters:
        idleTimeout - the idle timeout
      • doStop

        protected void doStop()
                       throws java.lang.Exception
        Description copied from class: ContainerLifeCycle
        Stops the managed lifecycle beans in the reverse order they were added.
        Overrides:
        doStop in class AbstractNetworkConnector
        Throws:
        java.lang.Exception - If there was a problem stopping. Will cause a transition to FAILED state
      • shutdown

        public java.util.concurrent.CompletableFuture<java.lang.Void> shutdown()
        Description copied from interface: Graceful
        Shutdown the component. When this method returns, the component should not accept any new load.
        Specified by:
        shutdown in interface Graceful
        Overrides:
        shutdown in class AbstractNetworkConnector
        Returns:
        A future that is completed once all load on the component is completed
      • getTransport

        public java.lang.Object getTransport()
        Returns:
        the underlying socket, channel, buffer etc. for the connector.