Package org.nuxeo.importer.stream.consumer

Class BlobMessageConsumerFactory

java.lang.Object

org.nuxeo.importer.stream.consumer.BlobMessageConsumerFactory

All Implemented Interfaces:

ConsumerFactory<BlobMessage>

public class BlobMessageConsumerFactory
extends Object
implements ConsumerFactory<BlobMessage>

Since:

9.1

Field Summary

Fields

Modifier and Type	Field	Description
protected final BlobInfoWriter	blobInfoWriter
protected final String	blobProviderName
protected final String	persistBlobPath
protected final String	watermarkPrefix

Constructor Summary

Constructors

Constructor	Description
BlobMessageConsumerFactory(String blobProviderName, BlobInfoWriter blobInfoWriter)	Blob Consumer factory requires a blob providerName that is present in Nuxeo instance running the consumer.
BlobMessageConsumerFactory(String blobProviderName, BlobInfoWriter blobInfoWriter, String watermarkPrefix)	Blob consumer that change the input blob to add a random watermark.
BlobMessageConsumerFactory(String blobProviderName, BlobInfoWriter blobInfoWriter, String watermarkPrefix, String persistBlobPath)	Blob consumer that change the input blob to add a random watermark and persist the generated blobs.

Method Summary

Modifier and Type	Method	Description
Consumer<BlobMessage>	createConsumer(String consumerId)

Methods inherited from class java.lang.Object

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

Field Details

blobProviderName

protected final String blobProviderName

blobInfoWriter

protected final BlobInfoWriter blobInfoWriter

watermarkPrefix

protected final String watermarkPrefix

persistBlobPath

protected final String persistBlobPath

Constructor Details

BlobMessageConsumerFactory

public BlobMessageConsumerFactory(String blobProviderName,
 BlobInfoWriter blobInfoWriter)

Blob Consumer factory requires a blob providerName that is present in Nuxeo instance running the consumer. The writer is used to store the blob information.

BlobMessageConsumerFactory

public BlobMessageConsumerFactory(String blobProviderName,
 BlobInfoWriter blobInfoWriter,
 String watermarkPrefix)

Blob consumer that change the input blob to add a random watermark.

BlobMessageConsumerFactory

public BlobMessageConsumerFactory(String blobProviderName,
 BlobInfoWriter blobInfoWriter,
 String watermarkPrefix,
 String persistBlobPath)

Blob consumer that change the input blob to add a random watermark and persist the generated blobs.

Method Details

createConsumer

public Consumer<BlobMessage> createConsumer(String consumerId)

Specified by:

createConsumer in interface ConsumerFactory<BlobMessage>

Parameters:

consumerId - the consumer identifier