@Override
	protected void doWrite(Message<?> message) throws Exception {
		Assert.notNull(storeWriter, "Writer already closed");
		Object payload = message.getPayload();
		if (payload instanceof String) {
			storeWriter.write((String) payload);
		}
		else {
			throw new MessageHandlingException(message,
					"message not a String");
		}
	}
Instantiates a new hdfs data store message handler.

@param storeWriter the store writer
spring-xd-hadoop/src/main/java/org/springframework/xd/integration/hadoop/outbound/HdfsDataStoreMessageHandler.java