org.springframework.xd.test.fixtures

Class AvailableSocketPorts

java.lang.Object

org.springframework.xd.test.fixtures.AvailableSocketPorts

public class AvailableSocketPorts
extends java.lang.Object

Utility class to find available server ports.

Leverages com.gemstone.gemfire.internal.net.SocketUtils#findAvailableServerSocket but in addition remembers the allocated ports. This is because the port may not be used immediately after it is found and thus may be re-ammocated on subsequent calls.

Author:

Eric Bottard

Method Summary

Methods

Modifier and Type	Method and Description
static void	ensureReady(AbstractModuleFixture<?> fixture, java.lang.String host, int port, int timeout) Verifies that the port to the broker is available.
static int	nextAvailablePort()

Methods inherited from class java.lang.Object

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

Method Detail

nextAvailablePort

public static int nextAvailablePort()

ensureReady

public static void ensureReady(AbstractModuleFixture<?> fixture,
               java.lang.String host,
               int port,
               int timeout)

Verifies that the port to the broker is available. If not throws an IllegalStateException.

Parameters:

fixtre - WThe module fixture is calling this method, used in case of exception

host - the host to connect to

port - the port to connect to

timeout - The max time to try to get the connection to the broker in milliseconds

Throws:

java.lang.IllegalStateException - if can not connect in the specified timeout.