@Override
	protected void onInit() throws Exception {
		super.onInit();
		Assert.notNull(storeWriter, "Data Writer must be set");
	}
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