public class RandomQueuesManager extends AbstractQueuesManager
Modifier and Type | Field and Description |
---|---|
protected Random |
rand |
log, maxQueueSize
Constructor and Description |
---|
RandomQueuesManager(ImporterLogger logger,
int queuesNb,
int maxQueueSize) |
Modifier and Type | Method and Description |
---|---|
protected int |
getTargetQueue(SourceNode bh,
int nbQueues) |
dispatch, getNBConsumers, getQueue, isQueueEmpty
public RandomQueuesManager(ImporterLogger logger, int queuesNb, int maxQueueSize)
protected int getTargetQueue(SourceNode bh, int nbQueues)
getTargetQueue
in class AbstractQueuesManager
Copyright © 2016 Nuxeo SA. All rights reserved.