@Override
	public void bindRequestor(String name, MessageChannel requests, MessageChannel replies,
			Properties properties) {
		if (logger.isInfoEnabled()) {
			logger.info("binding requestor: " + name);
		}
		Assert.isInstanceOf(SubscribableChannel.class, requests);
		validateProducerProperties(name, properties, SUPPORTED_REQUESTING_PRODUCER_PROPERTIES);
		RedisQueueOutboundChannelAdapter queue = new RedisQueueOutboundChannelAdapter("queue." + applyRequests(name),
				this.connectionFactory);
		queue.setBeanFactory(this.getBeanFactory());
		queue.afterPropertiesSet();
		String replyQueueName = name + ".replies." + this.getIdGenerator().generateId();
		RedisPropertiesAccessor accessor = new RedisPropertiesAccessor(properties);
		this.doRegisterProducer(name, requests, queue, replyQueueName, accessor);
		MessageProducerSupport adapter = createInboundAdapter(accessor, replyQueueName);
		this.doRegisterConsumer(name, name, replies, adapter, accessor);
	}
Send the failed message to 'ERRORS:[name]'.
spring-xd-messagebus-redis/src/main/java/org/springframework/xd/dirt/integration/redis/RedisMessageBus.java