Uses of Class
org.nuxeo.importer.stream.message.BlobMessage
Package
Description
-
Uses of BlobMessage in org.nuxeo.importer.stream
-
Uses of BlobMessage in org.nuxeo.importer.stream.consumer
Modifier and TypeMethodDescriptionvoid
BlobMessageConsumer.accept
(BlobMessage message) protected BlobMessageConsumer.CloseableBlob
BlobWatermarkMessageConsumer.addWatermark
(BlobMessage message, String watermark, Watermarker watermarker) protected BlobMessageConsumer.CloseableBlob
BlobMessageConsumer.getBlob
(BlobMessage message) protected BlobMessageConsumer.CloseableBlob
BlobWatermarkMessageConsumer.getBlob
(BlobMessage message) protected void
BlobMessageConsumer.saveBlobInfo
(BlobMessage message, String digest, long length, File blobFile) -
Uses of BlobMessage in org.nuxeo.importer.stream.message
-
Uses of BlobMessage in org.nuxeo.importer.stream.producer
Modifier and TypeMethodDescriptionFileBlobMessageProducer.next()
RandomStringBlobMessageProducer.next()
Modifier and TypeMethodDescriptionFileBlobMessageProducerFactory.createProducer
(int producerId) RandomStringBlobMessageProducerFactory.createProducer
(int producerId) Modifier and TypeMethodDescriptionint
FileBlobMessageProducer.getPartition
(BlobMessage message, int partitions) int
RandomStringBlobMessageProducer.getPartition
(BlobMessage message, int partitions)