private void bindJobTap(String jobName) {
		MessageChannel alreadyBound = jobTapChannels.putIfAbsent(jobName, new QueueChannel());
		if (alreadyBound == null) {
			getMessageBus().bindPubSubConsumer("tap:job:" + jobName, jobTapChannels.get(jobName), null);
		}
	}
Launch a job that is already deployed
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractJobIntegrationTest.java