| Package | Description |
|---|---|
| org.nuxeo.importer.stream.consumer | |
| org.nuxeo.lib.stream.pattern.consumer | |
| org.nuxeo.lib.stream.pattern.consumer.internals |
| Class and Description |
|---|
| AbstractConsumer |
| Consumer
A consumer consumes
Message by batch. |
| ConsumerFactory |
| ConsumerPolicy
The consumer policy drive the consumer pool and runner.
|
| ConsumerPolicyBuilder |
| ConsumerPool
Run a pool of ConsumerRunner.
|
| Class and Description |
|---|
| BatchPolicy
Describe when a batch must be flushed.
|
| BatchPolicy.Builder |
| Consumer
A consumer consumes
Message by batch. |
| ConsumerFactory |
| ConsumerPolicy
The consumer policy drive the consumer pool and runner.
|
| ConsumerPolicy.StartOffset |
| ConsumerPolicyBuilder |
| ConsumerStatus
The return status of a
ConsumerRunner |
| Class and Description |
|---|
| BatchPolicy
Describe when a batch must be flushed.
|
| Consumer
A consumer consumes
Message by batch. |
| ConsumerFactory |
| ConsumerPolicy
The consumer policy drive the consumer pool and runner.
|
| ConsumerStatus
The return status of a
ConsumerRunner |
Copyright © 2019 Nuxeo. All rights reserved.