@Override
		protected void handleMessageInternal(Message<?> message) throws Exception {
			MessageValues transformed = serializePayloadIfNecessary(message);

			if (replyTo != null) {
				transformed.put(XdHeaders.REPLY_TO, this.replyTo);
			}
			if (this.partitioningMetadata.isPartitionedModule()) {

				transformed.put(PARTITION_HEADER, determinePartition(message, this.partitioningMetadata));
			}

			byte[] messageToSend = embeddedHeadersMessageConverter.embedHeaders(transformed,
					RedisMessageBus.this.headersToMap);
			delegate.handleMessage(MessageBuilder.withPayload(messageToSend).copyHeaders(transformed).build());
		}
Send the failed message to 'ERRORS:[name]'.
spring-xd-messagebus-redis/src/main/java/org/springframework/xd/dirt/integration/redis/RedisMessageBus.java