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<BlobMessage> |
BlobMessageConsumerFactory.createConsumer(int consumerId) |
Modifier and Type | Method and Description |
---|---|
void |
BlobMessageConsumer.accept(BlobMessage message) |
Modifier and Type | Method and Description |
---|---|
BlobMessage |
BlobMessage.StringMessageBuilder.build() |
Modifier and Type | Method and Description |
---|---|
BlobMessage |
FileBlobMessageProducer.next() |
BlobMessage |
RandomStringBlobMessageProducer.next() |
Modifier and Type | Method and Description |
---|---|
ProducerIterator<BlobMessage> |
RandomStringBlobMessageProducerFactory.createProducer(int producerId) |
ProducerIterator<BlobMessage> |
FileBlobMessageProducerFactory.createProducer(int producerId) |
Modifier and Type | Method and Description |
---|---|
int |
FileBlobMessageProducer.getShard(BlobMessage message,
int shards) |
int |
RandomStringBlobMessageProducer.getShard(BlobMessage message,
int shards) |
Copyright © 2017 Nuxeo. All rights reserved.