public abstract class AbstractQueuesManager extends Object implements QueuesManager
Modifier and Type | Field and Description |
---|---|
protected ImporterLogger |
log |
protected int |
maxQueueSize |
Constructor and Description |
---|
AbstractQueuesManager(ImporterLogger logger,
int queuesNb,
int maxQueueSize) |
Modifier and Type | Method and Description |
---|---|
int |
dispatch(SourceNode bh) |
int |
getNBConsumers() |
BlockingQueue<SourceNode> |
getQueue(int idx) |
protected abstract int |
getTargetQueue(SourceNode bh,
int nbQueues) |
boolean |
isQueueEmpty(int idQueue) |
protected int maxQueueSize
protected ImporterLogger log
public AbstractQueuesManager(ImporterLogger logger, int queuesNb, int maxQueueSize)
public BlockingQueue<SourceNode> getQueue(int idx)
getQueue
in interface QueuesManager
public boolean isQueueEmpty(int idQueue)
isQueueEmpty
in interface QueuesManager
public int dispatch(SourceNode bh) throws InterruptedException
dispatch
in interface QueuesManager
InterruptedException
protected abstract int getTargetQueue(SourceNode bh, int nbQueues)
public int getNBConsumers()
getNBConsumers
in interface QueuesManager
Copyright © 2016 Nuxeo SA. All rights reserved.