private synchronized ExecutorChannel findOrCreateRequestReplyChannel(String name, String prefix,
			Properties properties) {
		String channelName = prefix + name;
		ExecutorChannel channel = this.requestReplyChannels.get(channelName);
		if (channel == null) {
			ThreadPoolTaskExecutor executor = createRequestReplyExecutor(name, properties);
			channel = new ExecutorChannel(executor);
			channel.setBeanFactory(getBeanFactory());
			this.requestReplyChannels.put(channelName, channel);
			this.reqRepExecutors.put(name, executor);
		}
		return channel;
	}
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