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 String |
persistBlobPath |
protected Integer |
retryDelayS |
protected Integer |
retryMax |
protected Integer |
waitMessageTimeoutSeconds |
protected String |
watermark |
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
protected String persistBlobPath
public BlobConsumers()
public void run() throws OperationException
OperationException
protected BlobInfoWriter getBlobInfoWriter(LogManager managerBlobInfo)
protected void initBlobInfoMQ(LogManager manager)
protected short getNbThreads()
protected String getLogName()
protected String getLogBlobInfoName()
protected String getLogConfig()
Copyright © 2019 Nuxeo. All rights reserved.