private ThreadPoolTaskExecutor createRequestReplyExecutor(String name, Properties properties) {
		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
		executor.setCorePoolSize(new LocalBusPropertiesAccessor(properties).getConcurrency(DEFAULT_REQ_REPLY_CONCURRENCY));
		executor.setThreadNamePrefix("xd.localBus." + name + "-");
		executor.initialize();
		return executor;
	}
Looks up or creates a DirectChannel with the given name and creates a bridge to that channel from the provided
channel instance.
spring-xd-messagebus-local/src/main/java/org/springframework/xd/dirt/integration/bus/local/LocalMessageBus.java