Package org.nuxeo.lib.stream.pattern.producer

Class AbstractProducer<M extends Message>

java.lang.Object

org.nuxeo.lib.stream.pattern.producer.AbstractProducer<M>

All Implemented Interfaces:

AutoCloseable, Iterator<M>, ProducerIterator<M>

Direct Known Subclasses:

FileBlobMessageProducer, RandomDocumentMessageProducer, RandomStringBlobMessageProducer

public abstract class AbstractProducer<M extends Message>
extends Object
implements ProducerIterator<M>

Since:

9.1

Field Summary

Fields

Modifier and Type	Field	Description
protected final int	producerId

Constructor Summary

Constructors

Constructor	Description
AbstractProducer(int producerId)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getProducerId()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next

Methods inherited from interface org.nuxeo.lib.stream.pattern.producer.ProducerIterator

getPartition, remove

Field Details

producerId

protected final int producerId

Constructor Details

AbstractProducer

public AbstractProducer(int producerId)

Method Details

getProducerId

public int getProducerId()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception