Class ProducerRunner<M extends Message>

java.lang.Object
org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner<M>
All Implemented Interfaces:
Callable<ProducerStatus>

public class ProducerRunner<M extends Message> extends Object implements Callable<ProducerStatus>
A callable pulling a producer iterator in loop.
Since:
9.1
  • Field Details

    • producerId

      protected final int producerId
    • appender

      protected final LogAppender<M extends Message> appender
    • factory

      protected final ProducerFactory<M extends Message> factory
    • threadName

      protected String threadName
    • registry

      protected final io.dropwizard.metrics5.MetricRegistry registry
    • producerTimer

      protected final io.dropwizard.metrics5.Timer producerTimer
    • producersCount

      protected final io.dropwizard.metrics5.Counter producersCount
    • counter

      protected long counter
  • Constructor Details

  • Method Details