public class RandomBlobProducers extends Object
Modifier and Type | Field and Description |
---|---|
protected Integer |
avgBlobSizeKB |
protected OperationContext |
ctx |
static String |
DEFAULT_MQ_NAME |
static String |
ID |
protected String |
kafkaConfig |
protected String |
lang |
protected String |
mqName |
protected Integer |
mqSize |
protected Integer |
nbBlobs |
protected Integer |
nbThreads |
Constructor and Description |
---|
RandomBlobProducers() |
Modifier and Type | Method and Description |
---|---|
protected static void |
checkAccess(OperationContext context) |
protected MQManager<BlobMessage> |
getManager() |
protected String |
getMQName() |
protected int |
getMQSize() |
void |
run() |
public static final String ID
public static final String DEFAULT_MQ_NAME
protected OperationContext ctx
protected Integer avgBlobSizeKB
protected String kafkaConfig
public RandomBlobProducers()
public void run()
protected int getMQSize()
protected MQManager<BlobMessage> getManager()
protected static void checkAccess(OperationContext context)
Copyright © 2017 Nuxeo. All rights reserved.