Interface | Description |
---|---|
Consumer<M extends Message> |
A consumer consumes
Message by batch. |
ConsumerFactory<M extends Message> |
Class | Description |
---|---|
AbstractCallablePool<T> |
Execute a pool of callables.
|
AbstractCallablePool.NamedThreadFactory | |
AbstractConsumer<M extends Message> | |
BatchPolicy |
Describe when a batch must be flushed.
|
BatchPolicy.Builder | |
BatchState |
Keep state of a batch according to a batch policy.
|
BlobMessageConsumer | |
BlobMessageConsumerFactory | |
ConsumerPolicy |
The consumer policy drive the consumer pool and runner.
|
ConsumerPolicy.Builder | |
ConsumerPool<M extends Message> |
Run a pool of ConsumerRunner.
|
ConsumerRunner<M extends Message> |
Read messages from a tailer and drive a consumer according to its policy.
|
ConsumerStatus |
The return status of a
ConsumerRunner |
DocumentConsumerPool<M extends Message> |
Block Nuxeo listeners during import.
|
DocumentMessageConsumer |
Consumes DocumentMessage and produce Nuxeo document.
|
DocumentMessageConsumerFactory |
Enum | Description |
---|---|
BatchState.State | |
ConsumerPolicy.StartOffset |
Copyright © 2017 Nuxeo. All rights reserved.