Uses of Class
org.nuxeo.importer.stream.message.BlobMessage

Packages that use BlobMessage

Package	Description
org.nuxeo.importer.stream.consumer
org.nuxeo.importer.stream.message
org.nuxeo.importer.stream.producer

Uses of BlobMessage in org.nuxeo.importer.stream.consumer

Methods in org.nuxeo.importer.stream.consumer that return types with arguments of type BlobMessage

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

Methods in org.nuxeo.importer.stream.consumer with parameters of type BlobMessage

Modifier and Type	Method and Description
void	BlobMessageConsumer.accept(BlobMessage message)
protected BlobMessageConsumer.CloseableBlob	BlobWatermarkMessageConsumer.addWatermark(BlobMessage message, String watermark, Watermarker watermarker)
protected BlobMessageConsumer.CloseableBlob	BlobWatermarkMessageConsumer.getBlob(BlobMessage message)
protected BlobMessageConsumer.CloseableBlob	BlobMessageConsumer.getBlob(BlobMessage message)
protected void	BlobMessageConsumer.saveBlobInfo(BlobMessage message, String digest, long length, File blobFile)

Uses of BlobMessage in org.nuxeo.importer.stream.message

Methods in org.nuxeo.importer.stream.message that return BlobMessage

Modifier and Type	Method and Description
BlobMessage	BlobMessage.StringMessageBuilder.build()

Uses of BlobMessage in org.nuxeo.importer.stream.producer

Methods in org.nuxeo.importer.stream.producer that return BlobMessage

Modifier and Type	Method and Description
BlobMessage	RandomStringBlobMessageProducer.next()
BlobMessage	FileBlobMessageProducer.next()

Methods in org.nuxeo.importer.stream.producer that return types with arguments of type BlobMessage

Modifier and Type	Method and Description
ProducerIterator<BlobMessage>	RandomStringBlobMessageProducerFactory.createProducer(int producerId)
ProducerIterator<BlobMessage>	FileBlobMessageProducerFactory.createProducer(int producerId)

Methods in org.nuxeo.importer.stream.producer with parameters of type BlobMessage

Modifier and Type	Method and Description
int	RandomStringBlobMessageProducer.getPartition(BlobMessage message, int partitions)
int	FileBlobMessageProducer.getPartition(BlobMessage message, int partitions)