org.nuxeo.lib.stream.pattern.producer

Interface ProducerIterator<M extends Message>

All Superinterfaces:

AutoCloseable, Iterator<M>

All Known Implementing Classes:

AbstractProducer, FileBlobMessageProducer, RandomDocumentMessageProducer, RandomStringBlobMessageProducer

public interface ProducerIterator<M extends Message>
extends Iterator<M>, AutoCloseable

A ProducerIterator returns Message. It also has the logic to return a partition index, that will be used to run concurrent consumers.

Since:

9.1

Method Summary

Modifier and Type	Method and Description
int	getPartition(M message, int partitions) Returns a partition associated with the Message.
default void	remove() The remove method is not needed.

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

remove

default void remove()

The remove method is not needed.

Specified by:

remove in interface Iterator<M extends Message>

getPartition

int getPartition(M message,
                 int partitions)

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