public class BlobConsumers extends Object
Modifier and Type | Field and Description |
---|---|
protected Integer |
batchSize |
protected Integer |
batchThresholdS |
protected String |
blobInfoPath |
protected String |
blobProviderName |
protected OperationContext |
ctx |
static String |
ID |
protected String |
kafkaConfig |
protected String |
mqName |
protected Integer |
nbThreads |
protected Integer |
retryDelayS |
protected Integer |
retryMax |
Constructor and Description |
---|
BlobConsumers() |
Modifier and Type | Method and Description |
---|---|
protected MQManager<BlobMessage> |
getManager() |
protected String |
getMQName() |
protected short |
getNbThreads() |
void |
run() |
public static final String ID
protected OperationContext ctx
protected String blobInfoPath
protected String blobProviderName
protected Integer batchThresholdS
protected Integer retryDelayS
protected String kafkaConfig
public BlobConsumers()
public void run()
protected short getNbThreads()
protected MQManager<BlobMessage> getManager()
Copyright © 2017 Nuxeo. All rights reserved.