@Override
	public void bindRequestor(final String name, MessageChannel requests, final MessageChannel replies,
			Properties properties) {
		validateConsumerProperties(name, properties, CONSUMER_REQUEST_REPLY_PROPERTIES);
		final MessageChannel requestChannel = this.findOrCreateRequestReplyChannel(name, "requestor.", properties);
		// TODO: handle Pollable ?
		Assert.isInstanceOf(SubscribableChannel.class, requests);
		((SubscribableChannel) requests).subscribe(new MessageHandler() {

			@Override
			public void handleMessage(Message<?> message) throws MessagingException {
				requestChannel.send(message);
			}
		});

		ExecutorChannel replyChannel = this.findOrCreateRequestReplyChannel(name, "replier.", properties);
		replyChannel.subscribe(new MessageHandler() {

			@Override
			public void handleMessage(Message<?> message) throws MessagingException {
				replies.send(message);
			}
		});
	}
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