Class ProducerRunner<M extends Message>
java.lang.Object
org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner<M>
- All Implemented Interfaces:
Callable<ProducerStatus>
A callable pulling a producer iterator in loop.
- Since:
- 9.1
-
Field Summary
Modifier and TypeFieldDescriptionprotected final LogAppender<M>
protected long
protected final ProducerFactory<M>
protected final int
protected final io.dropwizard.metrics5.Counter
protected final io.dropwizard.metrics5.Timer
protected final io.dropwizard.metrics5.MetricRegistry
protected String
-
Constructor Summary
ConstructorDescriptionProducerRunner
(ProducerFactory<M> factory, LogAppender<M> appender, int producerId) -
Method Summary
Modifier and TypeMethodDescriptioncall()
protected void
producerLoop
(ProducerIterator<M> producer) protected void
setThreadName
(M message)
-
Field Details
-
producerId
protected final int producerId -
appender
-
factory
-
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
-
ProducerRunner
-
-
Method Details