public class FileBlobMessageProducerFactory extends Object implements ProducerFactory<BlobMessage>
Modifier and Type | Field and Description |
---|---|
protected String |
basePath |
protected File |
listFile |
protected long |
nbBlobs |
Constructor and Description |
---|
FileBlobMessageProducerFactory(File listFile,
String basePath,
long nbBlobs)
Produce messages to import files listed in the listFile.
|
Modifier and Type | Method and Description |
---|---|
ProducerIterator<BlobMessage> |
createProducer(int producerId) |
protected final long nbBlobs
public FileBlobMessageProducerFactory(File listFile, String basePath, long nbBlobs)
public ProducerIterator<BlobMessage> createProducer(int producerId)
createProducer
in interface ProducerFactory<BlobMessage>
producerId
- the producer indexCopyright © 2018 Nuxeo. All rights reserved.