public abstract class AbstractProducer extends AbstractTaskRunner implements Producer
Modifier and Type | Field and Description |
---|---|
protected ImporterLogger |
log |
protected com.codahale.metrics.Counter |
producerCounter |
protected QueuesManager |
qm |
protected com.codahale.metrics.MetricRegistry |
registry |
canStop, completed, error, mustStop, nbProcessed, started
Constructor and Description |
---|
AbstractProducer(ImporterLogger log) |
Modifier and Type | Method and Description |
---|---|
protected void |
dispatch(SourceNode node) |
void |
init(QueuesManager qm) |
canStop, getError, getNbProcessed, incrementProcessed, isCompleted, isTerminated, mustStop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
canStop, getError, getNbProcessed, isCompleted, isTerminated, mustStop
protected ImporterLogger log
protected QueuesManager qm
protected final com.codahale.metrics.MetricRegistry registry
protected final com.codahale.metrics.Counter producerCounter
public AbstractProducer(ImporterLogger log)
public void init(QueuesManager qm)
protected void dispatch(SourceNode node) throws InterruptedException
InterruptedException
Copyright © 2016 Nuxeo SA. All rights reserved.