public class ConsumerRunner<M extends Message> extends Object implements Callable<ConsumerStatus>
Modifier and Type | Field and Description |
---|---|
protected com.codahale.metrics.Timer |
acceptTimer |
protected com.codahale.metrics.Timer |
batchCommitTimer |
protected com.codahale.metrics.Counter |
batchFailureCount |
protected com.codahale.metrics.Counter |
committedCounter |
protected com.codahale.metrics.Counter |
consumersCount |
static String |
NUXEO_METRICS_REGISTRY_NAME |
protected com.codahale.metrics.MetricRegistry |
registry |
Constructor and Description |
---|
ConsumerRunner(ConsumerFactory<M> factory,
ConsumerPolicy policy,
MQueues.Tailer<M> tailer) |
public static final String NUXEO_METRICS_REGISTRY_NAME
protected final com.codahale.metrics.MetricRegistry registry
protected final com.codahale.metrics.Timer acceptTimer
protected final com.codahale.metrics.Counter committedCounter
protected final com.codahale.metrics.Timer batchCommitTimer
protected final com.codahale.metrics.Counter batchFailureCount
protected final com.codahale.metrics.Counter consumersCount
public ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, MQueues.Tailer<M> tailer)
public ConsumerStatus call() throws Exception
call
in interface Callable<ConsumerStatus>
Exception
Copyright © 2017 Nuxeo. All rights reserved.