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 | Field and Description |
---|---|
protected MQOffset |
MQRecord.offset |
Modifier and Type | Method and Description |
---|---|
MQOffset |
MQAppender.append(int partition,
M message)
Append a message into a partition, returns
MQOffset position of the message. |
default MQOffset |
MQAppender.append(String key,
M message)
Same as
MQAppender.append(int, Externalizable) , the queue is chosen using a hash of . |
MQOffset |
MQTailer.commit(MQPartition partition)
Commit current position for the partition.
|
MQOffset |
MQRecord.offset()
Returns the offset of the message.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MQAppender.waitFor(MQOffset offset,
String group,
Duration timeout)
Wait for consumer to process a message up to the offset.
|
Constructor and Description |
---|
MQRecord(MQPartition partition,
M message,
MQOffset offset) |
Modifier and Type | Method and Description |
---|---|
MQOffset |
ChronicleMQAppender.append(int partition,
M message) |
MQOffset |
ChronicleMQTailer.commit(MQPartition partition) |
MQOffset |
ChronicleCompoundMQTailer.commit(MQPartition partition) |
Modifier and Type | Method and Description |
---|---|
void |
ChronicleMQTailer.seek(MQPartition partition,
MQOffset offset) |
void |
ChronicleCompoundMQTailer.seek(MQPartition partition,
MQOffset offset) |
boolean |
ChronicleMQAppender.waitFor(MQOffset offset,
String group,
Duration timeout) |
Modifier and Type | Class and Description |
---|---|
class |
MQOffsetImpl |
Modifier and Type | Method and Description |
---|---|
int |
MQOffsetImpl.compareTo(MQOffset o) |
Modifier and Type | Method and Description |
---|---|
MQOffset |
KafkaMQAppender.append(int partition,
Externalizable message) |
MQOffset |
KafkaMQTailer.commit(MQPartition partition) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaMQTailer.seek(MQPartition partition,
MQOffset offset) |
boolean |
KafkaMQAppender.waitFor(MQOffset offset,
String group,
Duration timeout) |
Copyright © 2017 Nuxeo. All rights reserved.