private String getEventListenerChannelName(String jobName, String driverJobName) {
		String tapName = String.format("tap:job:%s.job", jobName);
		if (this.messageBus.isCapable(Capability.DURABLE_PUBSUB)) {
			tapName = BusUtils.addGroupToPubSub(driverJobName, tapName);
		}
		return tapName;
	}
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