Package | Description |
---|---|
org.nuxeo.importer.stream.consumer | |
org.nuxeo.lib.stream.pattern.consumer | |
org.nuxeo.lib.stream.pattern.consumer.internals |
Modifier and Type | Class and Description |
---|---|
class |
BlobMessageConsumer
Import BlobMessage into a Nuxeo BlobProvider, persist BlobInformation.
|
class |
BlobWatermarkMessageConsumer
Consume blobMessages and generate new blob by adding a unique watermark.
|
class |
DocumentMessageConsumer
Consumes DocumentMessage and produce Nuxeo document.
|
class |
RedisDocumentMessageConsumer
Consumes DocumentMessage and send them to Redis which can be used as Gatling feeder.
|
Modifier and Type | Method and Description |
---|---|
Consumer<BlobMessage> |
BlobMessageConsumerFactory.createConsumer(String consumerId) |
Consumer<DocumentMessage> |
DocumentMessageConsumerFactory.createConsumer(String consumerId) |
Consumer<DocumentMessage> |
RedisDocumentMessageConsumerFactory.createConsumer(String consumerId) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractConsumer<M extends Message> |
Modifier and Type | Method and Description |
---|---|
Consumer<M> |
ConsumerFactory.createConsumer(String consumerId) |
Modifier and Type | Field and Description |
---|---|
protected Consumer<M> |
ConsumerRunner.consumer |
Copyright © 2018 Nuxeo. All rights reserved.