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 and Description
protected LogAppender<M>	appender
protected long	counter
protected ProducerFactory<M>	factory
protected int	producerId
protected com.codahale.metrics.Counter	producersCount
protected com.codahale.metrics.Timer	producerTimer
protected com.codahale.metrics.MetricRegistry	registry
protected String	threadName

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

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 com.codahale.metrics.MetricRegistry registry

producerTimer

protected final com.codahale.metrics.Timer producerTimer

producersCount

protected final com.codahale.metrics.Counter producersCount

counter

protected long counter

Constructor Detail

ProducerRunner

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

Method Detail

call

public ProducerStatus call()
                    throws Exception

Specified by:

call in interface Callable<ProducerStatus>

Throws:

Exception

producerLoop

protected void producerLoop(ProducerIterator<M> producer)

setThreadName

protected void setThreadName(M message)