Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer | |
org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer.internals |
Modifier and Type | Class and Description |
---|---|
class |
BlobMessageConsumerFactory |
class |
DocumentMessageConsumerFactory |
Constructor and Description |
---|
ConsumerPool(String mqName,
MQManager<M> manager,
ConsumerFactory<M> factory,
ConsumerPolicy policy) |
DocumentConsumerPool(String mqName,
MQManager<M> manager,
ConsumerFactory<M> factory,
ConsumerPolicy consumerPolicy) |
Constructor and Description |
---|
ConsumerRunner(ConsumerFactory<M> factory,
ConsumerPolicy policy,
MQManager<M> manager,
List<MQPartition> defaultAssignments) |
Copyright © 2017 Nuxeo. All rights reserved.