Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.automation | |
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 | |
org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer.internals | |
org.nuxeo.ecm.platform.importer.mqueues.pattern.producer | |
org.nuxeo.ecm.platform.importer.mqueues.pattern.producer.internals | |
org.nuxeo.ecm.platform.importer.mqueues.workmanager |
Class and Description |
---|
MQManager
Manage MQueue and give access to appender and tailers.
|
Class and Description |
---|
MQManager
Manage MQueue and give access to appender and tailers.
|
MQPartition
A tuple to store MQueue name and the partition index.
|
MQRebalanceListener
Listener to be notified on partition rebalancing.
|
Class and Description |
---|
MQAppender
An appender is used to append message into a MQueue.
|
MQOffset
A message position in a MQueue partition.
|
MQPartition
A tuple to store MQueue name and the partition index.
|
MQRebalanceListener
Listener to be notified on partition rebalancing.
|
MQRecord
A MQRecord contains the message and source information.
|
MQTailer
Sequential reader for a partition or multiple partitions.
|
Class and Description |
---|
MQAppender
An appender is used to append message into a MQueue.
|
MQManager
Manage MQueue and give access to appender and tailers.
|
MQOffset
A message position in a MQueue partition.
|
MQPartition
A tuple to store MQueue name and the partition index.
|
MQRebalanceListener
Listener to be notified on partition rebalancing.
|
MQRecord
A MQRecord contains the message and source information.
|
MQTailer
Sequential reader for a partition or multiple partitions.
|
Class and Description |
---|
MQAppender
An appender is used to append message into a MQueue.
|
MQManager
Manage MQueue and give access to appender and tailers.
|
MQOffset
A message position in a MQueue partition.
|
MQPartition
A tuple to store MQueue name and the partition index.
|
MQRebalanceListener
Listener to be notified on partition rebalancing.
|
MQTailer
Sequential reader for a partition or multiple partitions.
|
Class and Description |
---|
MQAppender
An appender is used to append message into a MQueue.
|
MQManager
Manage MQueue and give access to appender and tailers.
|
MQOffset
A message position in a MQueue partition.
|
MQPartition
A tuple to store MQueue name and the partition index.
|
MQRebalanceListener
Listener to be notified on partition rebalancing.
|
MQRecord
A MQRecord contains the message and source information.
|
MQTailer
Sequential reader for a partition or multiple partitions.
|
Class and Description |
---|
MQManager
Manage MQueue and give access to appender and tailers.
|
Class and Description |
---|
MQManager
Manage MQueue and give access to appender and tailers.
|
MQPartition
A tuple to store MQueue name and the partition index.
|
MQRebalanceListener
Listener to be notified on partition rebalancing.
|
Class and Description |
---|
MQManager
Manage MQueue and give access to appender and tailers.
|
Class and Description |
---|
MQAppender
An appender is used to append message into a MQueue.
|
Class and Description |
---|
MQManager
Manage MQueue and give access to appender and tailers.
|
Copyright © 2017 Nuxeo. All rights reserved.