private void processResult(StepContribution contribution, ChunkContext chunkContext, JobExecution results) {
		contribution.setExitStatus(results.getExitStatus());
		if (results.getStatus().isUnsuccessful()) {
			chunkContext.getStepContext()
					.getStepExecution()
					.getExecutionContext()
					.put(ExpandedJobParametersConverter.UNIQUE_JOB_PARAMETER_KEY,
							results.getJobParameters().getString(ExpandedJobParametersConverter.UNIQUE_JOB_PARAMETER_KEY));
			throw new UnexpectedJobExecutionException(String.format("Step failure: %s failed.", jobName));
		}
	}
Uses the {@link MessageBus} to execute a job deployed in a Spring XD cluster.

@param contribution The contribution to the step's metrics.  Not used in this case
@param chunkContext Used to get a handle on the JobExecution and JobInstance
@return RepeatStatus.FINISHED
@throws Exception
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/batch/tasklet/JobLaunchingTasklet.java