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

Packages that use BlobMessage

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

Uses of BlobMessage in org.nuxeo.importer.stream

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

Modifier and Type	Method	Description
static Codec<BlobMessage>	StreamImporters.getBlobCodec()

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	Description
Consumer<BlobMessage>	BlobMessageConsumerFactory.createConsumer(String consumerId)

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

Modifier and Type	Method	Description
void	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

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

Modifier and Type	Method	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	Description
BlobMessage	FileBlobMessageProducer.next()
BlobMessage	RandomStringBlobMessageProducer.next()

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

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

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

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