protected void triggerJobWithParams(String jobName, String parameters) {
		String streamName = generateStreamName();
		CommandResult cr = getShell().executeCommand(
				String.format("stream create --name " + streamName
						+ " --definition \"trigger --payload='%s' > " + getJobLaunchQueue(jobName)
						+ "\" --deploy true", parameters.replaceAll("\"", "\\\\\"")));
		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