}
@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);
}
}