Interface | Description |
---|---|
Consumer<M extends Message> |
A consumer consumes
Message by batch. |
ConsumerFactory<M extends Message> |
Class | Description |
---|---|
AbstractConsumer<M extends Message> | |
BatchPolicy |
Describe when a batch must be flushed.
|
BatchPolicy.Builder | |
BlobMessageConsumer | |
BlobMessageConsumerFactory | |
ConsumerPolicy |
The consumer policy drive the consumer pool and runner.
|
ConsumerPolicyBuilder | |
ConsumerPool<M extends Message> |
Run a pool of ConsumerRunner.
|
ConsumerStatus |
The return status of a
ConsumerRunner |
DocumentConsumerPolicy | |
DocumentConsumerPolicyBuilder | |
DocumentConsumerPool<M extends Message> |
Consumer Pool that block Nuxeo listeners during import.
|
DocumentMessageConsumer |
Consumes DocumentMessage and produce Nuxeo document.
|
DocumentMessageConsumerFactory |
Enum | Description |
---|---|
ConsumerPolicy.StartOffset |
Copyright © 2017 Nuxeo. All rights reserved.