Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.computation.mqueue |
Computation pattern with an implementation using MQueue.
|
org.nuxeo.ecm.platform.importer.mqueues.mqueues |
The MQueue interface with Chronicle and Kafka implementation.
|
org.nuxeo.ecm.platform.importer.mqueues.mqueues.chronicle | |
org.nuxeo.ecm.platform.importer.mqueues.mqueues.internals | |
org.nuxeo.ecm.platform.importer.mqueues.mqueues.kafka | |
org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer.internals |
Modifier and Type | Class and Description |
---|---|
class |
MQComputationRunner
Thread driving a Computation
|
Modifier and Type | Method and Description |
---|---|
MQTailer<M> |
MQManager.subscribe(String group,
Collection<String> names,
MQRebalanceListener listener)
Create a tailer for a consumer
group and subscribe to multiple MQueues. |
Modifier and Type | Method and Description |
---|---|
protected MQTailer<M> |
ChronicleMQManager.doSubscribe(String group,
Collection<String> names,
MQRebalanceListener listener) |
Modifier and Type | Method and Description |
---|---|
protected abstract MQTailer<M> |
AbstractMQManager.doSubscribe(String group,
Collection<String> names,
MQRebalanceListener listener) |
MQTailer<M> |
AbstractMQManager.subscribe(String group,
Collection<String> names,
MQRebalanceListener listener) |
Modifier and Type | Method and Description |
---|---|
static <M extends Externalizable> |
KafkaMQTailer.createAndSubscribe(String prefix,
Collection<String> names,
String group,
Properties consumerProps,
MQRebalanceListener listener) |
protected MQTailer<M> |
KafkaMQManager.doSubscribe(String group,
Collection<String> names,
MQRebalanceListener listener) |
Modifier and Type | Class and Description |
---|---|
class |
ConsumerRunner<M extends Message>
Read messages from a tailer and drive a consumer according to its policy.
|
Copyright © 2017 Nuxeo. All rights reserved.