Modifier and Type | Method and Description |
---|---|
protected MQManager<DocumentMessage> |
RandomDocumentProducers.getManager() |
protected MQManager<DocumentMessage> |
DocumentConsumers.getManager() |
protected MQManager<BlobMessage> |
BlobConsumers.getManager() |
protected MQManager<BlobMessage> |
RandomBlobProducers.getManager() |
Constructor and Description |
---|
MQComputationManager(MQManager<Record> manager,
Topology topology,
Settings settings) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ChronicleMQManager<M extends Externalizable> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMQManager<M extends Externalizable> |
Modifier and Type | Class and Description |
---|---|
class |
KafkaMQManager<M extends Externalizable> |
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) |
Constructor and Description |
---|
ProducerPool(String mqName,
MQManager<M> manager,
ProducerFactory<M> factory,
short nbThreads) |
Modifier and Type | Field and Description |
---|---|
protected MQManager<Record> |
WorkManagerComputation.mqManager |
Modifier and Type | Method and Description |
---|---|
protected abstract MQManager<Record> |
WorkManagerComputation.initStream() |
protected MQManager<Record> |
WorkManagerComputationChronicle.initStream() |
protected MQManager<Record> |
WorkManagerComputationKafka.initStream() |
Copyright © 2017 Nuxeo. All rights reserved.