Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.consumer | |
org.nuxeo.ecm.platform.importer.mqueues.mqueues | |
org.nuxeo.ecm.platform.importer.mqueues.producer |
Constructor and Description |
---|
ConsumerPool(MQueues<M> qm,
ConsumerFactory<M> factory,
ConsumerPolicy policy) |
DocumentConsumerPool(MQueues<M> qm,
ConsumerFactory<M> factory,
ConsumerPolicy policy) |
Modifier and Type | Class and Description |
---|---|
class |
CQMQueues<M extends Message>
Chronicle Queue implementation of MQueues.
|
Constructor and Description |
---|
ProducerPool(MQueues<M> mq,
ProducerFactory<M> factory,
int nbThreads) |
ProducerRunner(ProducerFactory<M> factory,
MQueues<M> mQueues,
int producerId) |
Copyright © 2017 Nuxeo. All rights reserved.