Modifier and Type | Method and Description |
---|---|
protected MQManager<BlobMessage> |
BlobConsumers.getManager() |
protected MQManager<BlobMessage> |
RandomBlobProducers.getManager() |
Modifier and Type | Method and Description |
---|---|
Consumer<BlobMessage> |
BlobMessageConsumerFactory.createConsumer(String 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.getPartition(BlobMessage message,
int partitions) |
int |
RandomStringBlobMessageProducer.getPartition(BlobMessage message,
int partitions) |
Copyright © 2017 Nuxeo. All rights reserved.