org.nuxeo.ecm.platform.importer.queue.producer

Class AbstractProducer

java.lang.Object

org.nuxeo.ecm.platform.importer.queue.AbstractTaskRunner

org.nuxeo.ecm.platform.importer.queue.producer.AbstractProducer

All Implemented Interfaces:

Runnable, Producer, TaskRunner

Direct Known Subclasses:

SourceNodeProducer

public abstract class AbstractProducer
extends AbstractTaskRunner
implements Producer

Since:

8.3

Field Summary

Fields

Modifier and Type	Field and Description
protected ImporterLogger	log
protected com.codahale.metrics.Counter	producerCounter
protected QueuesManager	qm
protected Random	rand
protected com.codahale.metrics.MetricRegistry	registry

Fields inherited from class org.nuxeo.ecm.platform.importer.queue.AbstractTaskRunner

canStop, completed, error, mustStop, nbProcessed, started

Constructor Summary

Constructors

Constructor and Description
AbstractProducer(ImporterLogger log)

Method Summary

Modifier and Type	Method and Description
protected void	dispatch(SourceNode node)
int	getTargetQueue(SourceNode bh, int nbQueues)
void	init(QueuesManager qm)

Methods inherited from class org.nuxeo.ecm.platform.importer.queue.AbstractTaskRunner

canStop, getError, getNbProcessed, incrementProcessed, isCompleted, isTerminated, mustStop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.nuxeo.ecm.platform.importer.queue.TaskRunner

canStop, getError, getNbProcessed, isCompleted, isTerminated, mustStop

Methods inherited from interface java.lang.Runnable

run

Field Detail

log

protected final ImporterLogger log

qm

protected QueuesManager qm

registry

protected final com.codahale.metrics.MetricRegistry registry

producerCounter

protected final com.codahale.metrics.Counter producerCounter

rand

protected final Random rand

Constructor Detail

AbstractProducer

public AbstractProducer(ImporterLogger log)

Method Detail

init

public void init(QueuesManager qm)

Specified by:

init in interface Producer

dispatch

protected void dispatch(SourceNode node)
                 throws InterruptedException

Throws:

InterruptedException

getTargetQueue

public int getTargetQueue(SourceNode bh,
                          int nbQueues)

Specified by:

getTargetQueue in interface Producer