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 | |
org.nuxeo.ecm.platform.importer.mqueues.pattern.producer.internals |
Modifier and Type | Method and Description |
---|---|
MQAppender<M> |
MQManager.getAppender(String name)
Get an appender for the MQueue named
name . |
Modifier and Type | Class and Description |
---|---|
class |
ChronicleMQAppender<M extends Externalizable>
Chronicle Queue implementation of MQAppender.
|
Modifier and Type | Method and Description |
---|---|
MQAppender<M> |
ChronicleMQManager.createAppender(String name) |
Modifier and Type | Method and Description |
---|---|
protected abstract MQAppender<M> |
AbstractMQManager.createAppender(String name) |
MQAppender<M> |
AbstractMQManager.getAppender(String name) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaMQAppender<M extends Externalizable>
Apache Kafka implementation of MQueue.
|
Modifier and Type | Method and Description |
---|---|
MQAppender<M> |
KafkaMQManager.createAppender(String name) |
Constructor and Description |
---|
ProducerRunner(ProducerFactory<M> factory,
MQAppender<M> mQueue,
int producerId) |
Copyright © 2017 Nuxeo. All rights reserved.