@Override
	public synchronized HdfsWritingMessageHandler getObject() throws Exception {
		if (handler == null) {
			DatasetWriterFactory writerFactory = new DatasetWriterFactory(this.datasetOperations);
			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 Thomas Risberg
spring-xd-hadoop/src/main/java/org/springframework/xd/integration/hadoop/config/DatasetWritingMessageHandlerFactoryBean.java