public void openSession ( SocketAddress endpoint ) { synchronized ( lock ) { // Submit a reconnect task for this address if one is not already present if ( ! pendingConnections . containsKey ( endpoint ) ) { final ReconnectTask task = new ReconnectTask ( endpoint ) ; pendingConnections . put ( endpoint , task ) ; this . reconnectExecutor . submit ( task ) ; } } }
Open a new session to the specified address . If session is being opened does nothing