Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.consumer | |
org.nuxeo.ecm.platform.importer.mqueues.mqueues |
Constructor and Description |
---|
ConsumerRunner(ConsumerFactory<M> factory,
ConsumerPolicy policy,
MQueues.Tailer<M> tailer) |
Modifier and Type | Class and Description |
---|---|
class |
CQTailer<M extends Message> |
Modifier and Type | Method and Description |
---|---|
MQueues.Tailer<M> |
MQueues.createTailer(int queue)
Create a new
MQueues.Tailer associed with the queue index. |
MQueues.Tailer<M> |
CQMQueues.createTailer(int queue) |
MQueues.Tailer<M> |
MQueues.createTailer(int queue,
String name)
Create a new
MQueues.Tailer associed to a queue index, using a specified offset name space. |
MQueues.Tailer<M> |
CQMQueues.createTailer(int queue,
String name) |
Copyright © 2017 Nuxeo. All rights reserved.