Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.consumer | |
org.nuxeo.ecm.platform.importer.mqueues.message | |
org.nuxeo.ecm.platform.importer.mqueues.producer |
Modifier and Type | Method and Description |
---|---|
Consumer<DocumentMessage> |
DocumentMessageConsumerFactory.createConsumer(int consumerId) |
Modifier and Type | Method and Description |
---|---|
void |
DocumentMessageConsumer.accept(DocumentMessage message) |
Modifier and Type | Method and Description |
---|---|
DocumentMessage |
DocumentMessage.Builder.build() |
Modifier and Type | Method and Description |
---|---|
DocumentMessage |
RandomDocumentMessageProducer.next() |
Modifier and Type | Method and Description |
---|---|
ProducerIterator<DocumentMessage> |
RandomDocumentMessageProducerFactory.createProducer(int producerId) |
Modifier and Type | Method and Description |
---|---|
int |
RandomDocumentMessageProducer.getShard(DocumentMessage message,
int shards) |
Copyright © 2017 Nuxeo. All rights reserved.