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 © 2018 Nuxeo. All rights reserved.