@Override
	public void bindPubSubProducer(final String name, MessageChannel moduleOutputChannel,
			Properties properties) {
		validateProducerProperties(name, properties, SUPPORTED_PUBSUB_PRODUCER_PROPERTIES);
		RedisPublishingMessageHandler topic = new RedisPublishingMessageHandler(connectionFactory);
		topic.setBeanFactory(this.getBeanFactory());
		topic.setTopic(applyPubSub(name));
		topic.afterPropertiesSet();
		doRegisterProducer(name, moduleOutputChannel, topic, new RedisPropertiesAccessor(properties));
	}
Send the failed message to 'ERRORS:[name]'.
spring-xd-messagebus-redis/src/main/java/org/springframework/xd/dirt/integration/redis/RedisMessageBus.java