Package org.nuxeo.importer.stream.automation

Class BlobConsumers

java.lang.Object

org.nuxeo.importer.stream.automation.BlobConsumers

public class BlobConsumers
extends Object

Since:

9.1

Field Summary

Fields

Modifier and Type	Field	Description
protected Integer	batchSize
protected Integer	batchThresholdS
protected String	blobProviderName
protected OperationContext	ctx
static String	ID
protected String	logBlobInfoName
protected String	logName
protected Integer	nbThreads
protected String	persistBlobPath
protected Integer	retryDelayS
protected Integer	retryMax
protected Integer	waitMessageTimeoutSeconds
protected String	watermark

Constructor Summary

Constructors

Constructor	Description
BlobConsumers()

Method Summary

Modifier and Type	Method	Description
protected BlobInfoWriter	getBlobInfoWriter(LogManager managerBlobInfo)
protected short	getNbThreads()
protected void	initBlobInfoMQ(LogManager manager)
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ID

public static final String ID

See Also:

Constant Field Values

ctx

protected OperationContext ctx

nbThreads

protected Integer nbThreads

blobProviderName

protected String blobProviderName

batchSize

protected Integer batchSize

batchThresholdS

protected Integer batchThresholdS

retryMax

protected Integer retryMax

retryDelayS

protected Integer retryDelayS

logName

protected String logName

logBlobInfoName

protected String logBlobInfoName

waitMessageTimeoutSeconds

protected Integer waitMessageTimeoutSeconds

watermark

protected String watermark

persistBlobPath

protected String persistBlobPath

Constructor Detail

BlobConsumers

public BlobConsumers()

Method Detail

run

public void run()
         throws OperationException

Throws:

OperationException

getBlobInfoWriter

protected BlobInfoWriter getBlobInfoWriter(LogManager managerBlobInfo)

initBlobInfoMQ

protected void initBlobInfoMQ(LogManager manager)

getNbThreads

protected short getNbThreads()