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

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 Summary

Fields

Modifier and Type	Field	Description
protected final LogAppender<M>	appender
protected long	counter
protected final ProducerFactory<M>	factory
protected final int	producerId
protected final io.dropwizard.metrics5.Counter	producersCount
protected final io.dropwizard.metrics5.Timer	producerTimer
protected final io.dropwizard.metrics5.MetricRegistry	registry
protected String	threadName

Constructor Summary

Constructors

Constructor	Description
ProducerRunner(ProducerFactory<M> factory, LogAppender<M> appender, int producerId)

Method Summary

Modifier and Type	Method	Description
ProducerStatus	call()
protected void	producerLoop(ProducerIterator<M> producer)
protected void	setThreadName(M message)

Methods inherited from class java.lang.Object

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

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

ProducerRunner

public ProducerRunner(ProducerFactory<M> factory,
 LogAppender<M> appender,
 int producerId)

Method Details

call

public ProducerStatus call()
                    throws Exception

Specified by:

call in interface Callable<M extends Message>

Throws:

Exception

producerLoop

protected void producerLoop(ProducerIterator<M> producer)

setThreadName

protected void setThreadName(M message)