@Override
	public synchronized HdfsWritingMessageHandler getObject() throws Exception {
		if (handler == null) {
			HdfsTextFileWriterFactory writerFactory = new HdfsTextFileWriterFactory(this.fileSystem);
			writerFactory.setBasePath(this.basePath);
			writerFactory.setBaseFilename(this.baseFilename);
			writerFactory.setFileSuffix(fileSuffix);
			writerFactory.setRolloverThresholdInBytes(rolloverThresholdInBytes);
			this.handler = new HdfsWritingMessageHandler(writerFactory);
			if (this.autoStartup != null) {
				this.handler.setAutoStartup(this.autoStartup);
			}
		}
		return this.handler;
	}
Factory bean used to create {@link HdfsWritingMessageHandler}

@author Mark Fisher
spring-xd-hadoop/src/main/java/org/springframework/xd/integration/hadoop/config/HdfsWritingMessageHandlerFactoryBean.java