@Override
	public void close() {
		if (fsDataOutputStream != null) {
			IOUtils.closeStream(fsDataOutputStream);
		}
	}
Extracts the payload as a byte array.

@param message
@return payload
spring-xd-hadoop/src/main/java/org/springframework/xd/hadoop/fs/HdfsTextFileWriter.java