| Package | Description |
|---|---|
| org.nuxeo.importer.stream.consumer | |
| org.nuxeo.importer.stream.message | |
| org.nuxeo.importer.stream.producer |
| Modifier and Type | Method and Description |
|---|---|
Consumer<DocumentMessage> |
DocumentMessageConsumerFactory.createConsumer(String consumerId) |
Consumer<DocumentMessage> |
RedisDocumentMessageConsumerFactory.createConsumer(String consumerId) |
| Modifier and Type | Method and Description |
|---|---|
void |
DocumentMessageConsumer.accept(DocumentMessage message) |
void |
RedisDocumentMessageConsumer.accept(DocumentMessage message) |
protected Blob |
DocumentMessageConsumer.getBlob(DocumentMessage message) |
protected String |
RedisDocumentMessageConsumer.getPayload(DocumentMessage message,
String properties) |
protected String |
RedisDocumentMessageConsumer.getProperties(DocumentMessage message) |
protected String |
RedisDocumentMessageConsumer.getPropertiesWithBlob(DocumentMessage message) |
| Modifier and Type | Method and Description |
|---|---|
DocumentMessage |
DocumentMessage.Builder.build() |
static DocumentMessage |
DocumentMessage.copy(DocumentMessage node,
String newName) |
| Modifier and Type | Method and Description |
|---|---|
static DocumentMessage |
DocumentMessage.copy(DocumentMessage node,
String newName) |
| Modifier and Type | Method and Description |
|---|---|
protected DocumentMessage |
RandomDocumentMessageProducer.createDocument(String parentPath,
Set<String> exclude) |
protected DocumentMessage |
RandomDocumentMessageProducer.createFolder(String parentPath,
Set<String> exclude) |
protected DocumentMessage |
RandomDocumentMessageProducer.createRoot() |
protected DocumentMessage |
RandomDocumentMessageProducer.getRandomNode(String type,
String parentPath,
boolean withBlob) |
protected DocumentMessage |
RandomDocumentMessageProducer.getRandomNodeWithExclusion(String type,
String parentPath,
boolean withBlob,
Set<String> exclude) |
protected DocumentMessage |
RandomDocumentMessageProducer.getRandomNodeWithPrefix(String prefix,
String type,
String parentPath) |
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 © 2019 Nuxeo. All rights reserved.