Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.computation | |
org.nuxeo.ecm.platform.importer.mqueues.computation.internals | |
org.nuxeo.ecm.platform.importer.mqueues.computation.mqueue |
Computation pattern with an implementation using MQueue.
|
Modifier and Type | Method and Description |
---|---|
ComputationMetadataMapping |
Topology.getMetadata(String name) |
Modifier and Type | Method and Description |
---|---|
List<ComputationMetadataMapping> |
Topology.metadataList() |
Constructor and Description |
---|
ComputationContextImpl(ComputationMetadataMapping metadata) |
Constructor and Description |
---|
MQComputationPool(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<List<MQPartition>> defaultAssignments,
MQManager<Record> manager) |
MQComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<MQPartition> defaultAssignment,
MQManager<Record> mqManager) |
Copyright © 2017 Nuxeo. All rights reserved.