Package org.nuxeo.importer.stream.producer

Class RandomStringBlobMessageProducerFactory

java.lang.Object

org.nuxeo.importer.stream.producer.RandomStringBlobMessageProducerFactory

All Implemented Interfaces:

ProducerFactory<BlobMessage>

public class RandomStringBlobMessageProducerFactory
extends Object
implements ProducerFactory<BlobMessage>

Since:

9.1

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	averageSizeKB
protected final String	lang
protected final String	marker
protected final long	nbBlobs

Constructor Summary

Constructors

Constructor	Description
RandomStringBlobMessageProducerFactory(long nbBlobs, String lang, int averageSizeKB, String marker)	Produce messages with a random blob content

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

nbBlobs

protected final long nbBlobs

lang

protected final String lang

averageSizeKB

protected final int averageSizeKB

marker

protected final String marker

Constructor Details

RandomStringBlobMessageProducerFactory

public RandomStringBlobMessageProducerFactory(long nbBlobs,
 String lang,
 int averageSizeKB,
 String marker)

Produce messages with a random blob content

Method Details

createProducer

public ProducerIterator<BlobMessage> createProducer(int producerId)

Specified by:

createProducer in interface ProducerFactory<BlobMessage>

Parameters:

producerId - the producer index