public abstract class AbstractProducer extends AbstractTaskRunner implements Producer
Modifier and Type | Field and Description |
---|---|
protected ImporterLogger |
log |
protected QueuesManager |
qm |
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
public AbstractProducer(ImporterLogger log)
public void init(QueuesManager qm)
protected void dispatch(SourceNode node) throws InterruptedException
InterruptedException
Copyright © 2016 Nuxeo SA. All rights reserved.