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 final String	basePath
protected final File	listFile
protected final long	nbBlobs

Constructor Summary

Constructors

Constructor	Description
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 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 Details

listFile

protected final File listFile

basePath

protected final String basePath

nbBlobs

protected final long nbBlobs

Constructor Details

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 Details

createProducer

public ProducerIterator<BlobMessage> createProducer(int producerId)

Specified by:

createProducer in interface ProducerFactory<BlobMessage>

Parameters:

producerId - the producer index