protected void doWrite(Message<?> message) {
		try {
			hdfsWriter.write(message);
		}
		catch (Exception e) {
			throw new MessageHandlingException(message,
					"failed to write Message payload to HDFS", e);
		}
	}
Spring Integration {@code MessageHandler} handling {@code Message} writing into hdfs using {@code HdfsWriter}.

@author Mark Pollack
@author Mark Fisher
spring-xd-hadoop/src/main/java/org/springframework/xd/integration/hadoop/outbound/HdfsWritingMessageHandler.java