Class VmPipeConnector

    • Constructor Detail

      • VmPipeConnector

        public VmPipeConnector()
        Creates a new instance.
      • VmPipeConnector

        public VmPipeConnector​(java.util.concurrent.Executor executor)
        Creates a new instance.
        Parameters:
        executor - The executor to use
    • Method Detail

      • getSessionConfig

        public VmPipeSessionConfig getSessionConfig()
        Returns:
        the default configuration of the new IoSessions created by this service.
      • connect0

        protected ConnectFuture connect0​(java.net.SocketAddress remoteAddress,
                                         java.net.SocketAddress localAddress,
                                         IoSessionInitializer<? extends ConnectFuture> sessionInitializer)
        Implement this method to perform the actual connect operation.
        Specified by:
        connect0 in class AbstractIoConnector
        Parameters:
        remoteAddress - The remote address to connect from
        localAddress - null if no local address is specified
        sessionInitializer - The IoSessionInitializer to use when the connection s successful
        Returns:
        The ConnectFuture associated with this asynchronous operation
      • dispose0

        protected void dispose0()
                         throws java.lang.Exception
        Implement this method to release any acquired resources. This method is invoked only once by AbstractIoService.dispose().
        Specified by:
        dispose0 in class AbstractIoService
        Throws:
        java.lang.Exception - If the dispose failed