org.apache.brooklyn.util.net

Class ReachableSocketFinder

java.lang.Object

org.apache.brooklyn.util.net.ReachableSocketFinder

public class ReachableSocketFinder
extends java.lang.Object

For finding an open/reachable ip:port for a node.

Constructor Summary

Constructors

Constructor and Description
ReachableSocketFinder(com.google.common.util.concurrent.ListeningExecutorService userExecutor)
ReachableSocketFinder(com.google.common.base.Predicate<? super com.google.common.net.HostAndPort> socketTester, com.google.common.util.concurrent.ListeningExecutorService userExecutor)

Method Summary

Modifier and Type	Method and Description
com.google.common.net.HostAndPort	findOpenSocketOnNode(java.util.Collection<? extends com.google.common.net.HostAndPort> sockets, Duration timeout)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReachableSocketFinder

public ReachableSocketFinder(com.google.common.util.concurrent.ListeningExecutorService userExecutor)

ReachableSocketFinder

public ReachableSocketFinder(com.google.common.base.Predicate<? super com.google.common.net.HostAndPort> socketTester,
                             com.google.common.util.concurrent.ListeningExecutorService userExecutor)

Method Detail

findOpenSocketOnNode

public com.google.common.net.HostAndPort findOpenSocketOnNode(java.util.Collection<? extends com.google.common.net.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