public RabbitSource ensureReady() {
		AvailableSocketPorts.ensureReady(this.getClass().getName(), connectionFactory.getHost(), connectionFactory.getPort(),
				2000);
		return this;
	}
Ensure that the Rabbit broker socket is available by polling it for up to 2 seconds

@return RabbitSource 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/RabbitSource.java