public RabbitSink ensureReady() {
		String[] addressArray = StringUtils.commaDelimitedListToStringArray(addresses);
		try {
			for (String address : addressArray) {
				URI uri = new URI(address);
				AvailableSocketPorts.ensureReady(this.getClass().getName(), uri.getHost(), uri.getPort(), 2000);
			}
		}
		catch (URISyntaxException uriSyntaxException) {
			throw new IllegalStateException(uriSyntaxException.getMessage(), uriSyntaxException);
		}
		return this;
	}
Ensure that the each Rabbit broker socket is available by polling it for up to 2 seconds

@return RabbitSink to use in fluent API chaining
@throws IllegalStateException if can not connect in 2 seconds.
spring-xd-test-fixtures/src/main/java/org/springframework/xd/test/fixtures/RabbitSink.java