public class BlobConsumers extends Object
Modifier and Type | Field and Description |
---|---|
protected Integer |
batchSize |
protected Integer |
batchThresholdS |
protected String |
blobProviderName |
protected OperationContext |
ctx |
static String |
DEFAULT_LOG_BLOB_INFO_NAME |
static String |
DEFAULT_LOG_CONFIG |
static String |
ID |
protected String |
logBlobInfoName |
protected String |
logConfig |
protected String |
logName |
protected Integer |
nbThreads |
protected Integer |
retryDelayS |
protected Integer |
retryMax |
protected Integer |
waitMessageTimeoutSeconds |
Constructor and Description |
---|
BlobConsumers() |
Modifier and Type | Method and Description |
---|---|
protected BlobInfoWriter |
getBlobInfoWriter(LogManager managerBlobInfo) |
protected String |
getLogBlobInfoName() |
protected String |
getLogConfig() |
protected String |
getLogName() |
protected short |
getNbThreads() |
protected void |
initBlobInfoMQ(LogManager manager) |
void |
run() |
public static final String ID
public static final String DEFAULT_LOG_BLOB_INFO_NAME
public static final String DEFAULT_LOG_CONFIG
protected OperationContext ctx
protected String blobProviderName
protected Integer batchThresholdS
protected Integer retryDelayS
protected String logBlobInfoName
protected Integer waitMessageTimeoutSeconds
public BlobConsumers()
public void run()
protected BlobInfoWriter getBlobInfoWriter(LogManager managerBlobInfo)
protected void initBlobInfoMQ(LogManager manager)
protected short getNbThreads()
protected String getLogName()
protected String getLogBlobInfoName()
protected String getLogConfig()
Copyright © 2018 Nuxeo. All rights reserved.