Class BlobConsumers
java.lang.Object
org.nuxeo.importer.stream.automation.BlobConsumers
- Since:
- 9.1
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected BlobInfoWriter
getBlobInfoWriter
(LogManager managerBlobInfo) protected short
protected void
initBlobInfoMQ
(LogManager manager) void
run()
-
Field Details
-
ID
- See Also:
-
ctx
-
nbThreads
-
blobProviderName
-
batchSize
-
batchThresholdS
-
retryMax
-
retryDelayS
-
logName
-
logBlobInfoName
-
waitMessageTimeoutSeconds
-
watermark
-
persistBlobPath
-
-
Constructor Details
-
BlobConsumers
public BlobConsumers()
-
-
Method Details
-
run
- Throws:
OperationException
-
getBlobInfoWriter
-
initBlobInfoMQ
-
getNbThreads
protected short getNbThreads()
-