public interface QueuesManager
Modifier and Type | Method and Description |
---|---|
int |
dispatch(SourceNode node) |
int |
getNBConsumers() |
BlockingQueue<SourceNode> |
getQueue(int idx) |
boolean |
isQueueEmpty(int idQueue) |
BlockingQueue<SourceNode> getQueue(int idx)
int dispatch(SourceNode node) throws InterruptedException
InterruptedException
int getNBConsumers()
boolean isQueueEmpty(int idQueue)
Copyright © 2016 Nuxeo SA. All rights reserved.