| 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.