protected void triggerJob(String jobName) {
		String streamName = generateStreamName();
		CommandResult cr = getShell().executeCommand(
				"stream create --name " + streamName + " --definition \"trigger > "
						+ getJobLaunchQueue(jobName) + "\" --deploy true");
		streams.add(streamName);
		waitForJobCompletion(jobName);
		checkForSuccess(cr);
	}
Launch a job that is already deployed
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractJobIntegrationTest.java