Package org.nuxeo.importer.stream.producer

Class FileBlobMessageProducerFactory

java.lang.Object

org.nuxeo.importer.stream.producer.FileBlobMessageProducerFactory

All Implemented Interfaces:

ProducerFactory<BlobMessage>

public class FileBlobMessageProducerFactory
extends Object
implements ProducerFactory<BlobMessage>

Since:

9.1

Field Summary

Fields

Modifier and Type	Field	Description
protected String	basePath
protected File	listFile
protected long	nbBlobs

Constructor Summary

Constructors

Constructor	Description
FileBlobMessageProducerFactory(File listFile, String basePath, long nbBlobs)	Produce messages to import files listed in the listFile.

Method Summary

Modifier and Type	Method	Description
ProducerIterator<BlobMessage>	createProducer(int producerId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

listFile

protected final File listFile

basePath

protected final String basePath

nbBlobs

protected final long nbBlobs

Constructor Detail

FileBlobMessageProducerFactory

public FileBlobMessageProducerFactory(File listFile,
                                      String basePath,
                                      long nbBlobs)

Produce messages to import files listed in the listFile. the basePath is added as a prefix to all file path in the listFile if nbBlobs = 0 the entire listFile is imported

Method Detail

createProducer

public ProducerIterator<BlobMessage> createProducer(int producerId)

Specified by:

createProducer in interface ProducerFactory<BlobMessage>

Parameters:

producerId - the producer index