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

Interface ProducerFactory<M extends Message>

All Known Implementing Classes:
FileBlobMessageProducerFactory, RandomDocumentMessageProducerFactory, RandomStringBlobMessageProducerFactory
public interface ProducerFactory<M extends Message>
Since:
9.1

  • Method Details

    • createProducer

      ProducerIterator<M> createProducer(int producerId)
      Parameters:
      producerId - the producer index