code: 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);
              }
          }
      }
docs: Open a new session to the specified address. If session is being
  opened does nothing
  
  @param endpoint