protected void verifyJobCreated(String jobName) throws InterruptedException {
		long expiry = System.currentTimeMillis() + STATE_TRANSITION_TIMEOUT;
		while (!streamExists(jobName) && System.currentTimeMillis() < expiry) {
			Thread.sleep(500);
		}
		assertTrue(jobExists(jobName));
	}
Assert that the given job has been created.

@param jobName  name of job to verify
spring-xd-distributed-test/src/test/java/org/springframework/xd/distributed/test/AbstractDistributedTests.java