Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.mqueues |
Modifier and Type | Class and Description |
---|---|
class |
CQOffset |
Modifier and Type | Method and Description |
---|---|
Offset |
MQueues.append(int queue,
M message)
Append a message into a queue, returns an
Offset . |
Offset |
MQueues.Tailer.commit()
Commit the offset of the last message returned by read.
|
Offset |
CQTailer.commit() |
Modifier and Type | Method and Description |
---|---|
int |
CQOffset.compareTo(Offset o) |
boolean |
MQueues.waitFor(Offset offset,
Duration timeout)
Wait for consumer to process a message up to the offset.
|
boolean |
CQMQueues.waitFor(Offset offset,
Duration timeout) |
Copyright © 2017 Nuxeo. All rights reserved.