@Override
	protected void doStop() {
		try {
			if (storeWriter != null) {
				storeWriter.close();
				storeWriter = null;
			}
		}
		catch (Exception e) {
			logger.error("Error closing writer", e);
		}
	}
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