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 © 2018 Nuxeo. All rights reserved.