public class ProducerRunner<M extends Message> extends Object implements Callable<ProducerStatus>
Modifier and Type | Field and Description |
---|---|
protected com.codahale.metrics.Counter |
producersCount |
protected com.codahale.metrics.Timer |
producerTimer |
protected com.codahale.metrics.MetricRegistry |
registry |
Constructor and Description |
---|
ProducerRunner(ProducerFactory<M> factory,
MQueues<M> mQueues,
int producerId) |
protected final com.codahale.metrics.MetricRegistry registry
protected final com.codahale.metrics.Timer producerTimer
protected final com.codahale.metrics.Counter producersCount
public ProducerRunner(ProducerFactory<M> factory, MQueues<M> mQueues, int producerId)
public ProducerStatus call() throws Exception
call
in interface Callable<ProducerStatus>
Exception
Copyright © 2017 Nuxeo. All rights reserved.