Package | Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
MQTailer<M> |
MQManager.createTailer(String group,
Collection<MQPartition> partitions)
Create a tailer for a consumer
group and assign multiple partitions . |
MQTailer<M> |
MQManager.createTailer(String group,
MQPartition partition)
Create a tailer for a consumer
group and assign a single partition . |
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 | Class and Description |
---|---|
class |
ChronicleCompoundMQTailer<M extends Externalizable> |
class |
ChronicleMQTailer<M extends Externalizable> |
Modifier and Type | Method and Description |
---|---|
protected MQTailer<M> |
ChronicleMQManager.acquireTailer(Collection<MQPartition> partitions,
String group) |
MQTailer<M> |
ChronicleMQAppender.createTailer(MQPartition partition,
String group) |
protected MQTailer<M> |
ChronicleMQManager.doSubscribe(String group,
Collection<String> names,
MQRebalanceListener listener) |
Modifier and Type | Method and Description |
---|---|
protected abstract MQTailer<M> |
AbstractMQManager.acquireTailer(Collection<MQPartition> partitions,
String group) |
MQTailer<M> |
AbstractMQManager.createTailer(String group,
Collection<MQPartition> partitions) |
MQTailer<M> |
AbstractMQManager.createTailer(String group,
MQPartition partition) |
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 | Class and Description |
---|---|
class |
KafkaMQTailer<M extends Externalizable> |
Modifier and Type | Method and Description |
---|---|
protected MQTailer<M> |
KafkaMQManager.acquireTailer(Collection<MQPartition> partitions,
String group) |
protected MQTailer<M> |
KafkaMQManager.doSubscribe(String group,
Collection<String> names,
MQRebalanceListener listener) |
Copyright © 2017 Nuxeo. All rights reserved.