Modifier and Type | Method and Description |
---|---|
protected MQManager<DocumentMessage> |
RandomDocumentProducers.getManager() |
protected MQManager<DocumentMessage> |
DocumentConsumers.getManager() |
Modifier and Type | Method and Description |
---|---|
Consumer<DocumentMessage> |
DocumentMessageConsumerFactory.createConsumer(String 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.getPartition(DocumentMessage message,
int partitions) |
Copyright © 2017 Nuxeo. All rights reserved.