public class BlobMessageConsumerFactory extends Object implements ConsumerFactory<BlobMessage>
Modifier and Type | Field and Description |
---|---|
protected BlobInfoWriter |
blobInfoWriter |
protected String |
blobProviderName |
protected String |
persistBlobPath |
protected String |
watermarkPrefix |
Constructor and 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.
|
Modifier and Type | Method and Description |
---|---|
Consumer<BlobMessage> |
createConsumer(String consumerId) |
protected final String blobProviderName
protected final BlobInfoWriter blobInfoWriter
protected final String watermarkPrefix
protected final String persistBlobPath
public BlobMessageConsumerFactory(String blobProviderName, BlobInfoWriter blobInfoWriter)
public BlobMessageConsumerFactory(String blobProviderName, BlobInfoWriter blobInfoWriter, String watermarkPrefix)
public BlobMessageConsumerFactory(String blobProviderName, BlobInfoWriter blobInfoWriter, String watermarkPrefix, String persistBlobPath)
public Consumer<BlobMessage> createConsumer(String consumerId)
createConsumer
in interface ConsumerFactory<BlobMessage>
consumerId
- the consumer identifierCopyright © 2019 Nuxeo. All rights reserved.