org.nuxeo.ecm.platform.importer.mqueues.pattern.producer

Class FileBlobMessageProducer

java.lang.Object

org.nuxeo.ecm.platform.importer.mqueues.pattern.producer.AbstractProducer<BlobMessage>

org.nuxeo.ecm.platform.importer.mqueues.pattern.producer.FileBlobMessageProducer

All Implemented Interfaces:

AutoCloseable, Iterator<BlobMessage>, ProducerIterator<BlobMessage>

public class FileBlobMessageProducer
extends AbstractProducer<BlobMessage>

Use a listing file to generate BlobMessage.

Since:

9.1

Constructor Summary

Constructors

Constructor and Description
FileBlobMessageProducer(int producerId, File listFile)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getPartition(BlobMessage message, int partitions) Returns a partition associated with the Message.
boolean	hasNext()
BlobMessage	next()

Methods inherited from class org.nuxeo.ecm.platform.importer.mqueues.pattern.producer.AbstractProducer

getProducerId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.nuxeo.ecm.platform.importer.mqueues.pattern.producer.ProducerIterator

remove

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

FileBlobMessageProducer

public FileBlobMessageProducer(int producerId,
                               File listFile)

Method Detail

getPartition

public int getPartition(BlobMessage message,
                        int partitions)

Description copied from interface: ProducerIterator

Returns a partition associated with the Message. The value returned must be between 0 and lower than partitions.

Parameters:

message - the message to shard

partitions - the number of partitions

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractProducer<BlobMessage>

Throws:

Exception

hasNext

public boolean hasNext()

next

public BlobMessage next()