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 int	averageSizeKB
protected String	lang
protected String	marker
protected 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 Detail

nbBlobs

protected final long nbBlobs

lang

protected final String lang

averageSizeKB

protected final int averageSizeKB

marker

protected final String marker

Constructor Detail

RandomStringBlobMessageProducerFactory

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

Produce messages with a random blob content

Method Detail

createProducer

public ProducerIterator<BlobMessage> createProducer(int producerId)

Specified by:

createProducer in interface ProducerFactory<BlobMessage>

Parameters:

producerId - the producer index