Constructor Detail

• ReachableSocketFinder

  public ReachableSocketFinder(ListeningExecutorService userExecutor)

• ReachableSocketFinder

  public ReachableSocketFinder( socketTester,
                       ListeningExecutorService userExecutor)

Method Detail

• findOpenSocketOnNode

  public HostAndPort findOpenSocketOnNode(java.util.Collection<? extends HostAndPort> sockets,
                                 Duration timeout)

  Parameters:

  sockets - The host-and-ports to test

  timeout - Max time to try to connect to the ip:port

  Returns:

  The reachable ip:port

  Throws:

  java.util.NoSuchElementException - If no ports accessible within the given time

  java.lang.NullPointerException - If the sockets or duration is null

  java.lang.IllegalStateException - If the sockets to test is empty