public class BlobWatermarkMessageConsumer extends BlobMessageConsumer
BlobMessageConsumer.CloseableBlob
Modifier and Type | Field and Description |
---|---|
protected String |
generatedBlobPath |
protected Watermarker |
jpegWatermarker |
protected Watermarker |
mp4Watermarker |
protected Path |
outputPath |
protected String |
prefix |
protected Watermarker |
textWatermarker |
blobInfoWriter, blobProvider, blobProviderName
consumerId
Constructor and Description |
---|
BlobWatermarkMessageConsumer(String consumerId,
String blobProviderName,
BlobInfoWriter blobInfoWriter,
String watermarkPrefix,
String persistBlobPath) |
Modifier and Type | Method and Description |
---|---|
protected BlobMessageConsumer.CloseableBlob |
addWatermark(BlobMessage message,
String watermark,
Watermarker watermarker) |
protected BlobMessageConsumer.CloseableBlob |
getBlob(BlobMessage message) |
protected String |
getWatermarkString() |
accept, begin, commit, rollback, saveBlobInfo
close, getConsumerId
protected final String generatedBlobPath
protected final Path outputPath
protected final Watermarker textWatermarker
protected final Watermarker jpegWatermarker
protected final Watermarker mp4Watermarker
public BlobWatermarkMessageConsumer(String consumerId, String blobProviderName, BlobInfoWriter blobInfoWriter, String watermarkPrefix, String persistBlobPath)
persistBlobPath
- when it is blank we don't delete generated blobsprotected BlobMessageConsumer.CloseableBlob getBlob(BlobMessage message)
getBlob
in class BlobMessageConsumer
protected BlobMessageConsumer.CloseableBlob addWatermark(BlobMessage message, String watermark, Watermarker watermarker)
protected String getWatermarkString()
Copyright © 2019 Nuxeo. All rights reserved.