Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.consumer | |
org.nuxeo.ecm.platform.importer.mqueues.producer |
Class and Description |
---|
AbstractCallablePool
Execute a pool of callables.
|
AbstractConsumer |
BatchPolicy
Describe when a batch must be flushed.
|
BatchPolicy.Builder |
BatchState.State |
Consumer
A consumer consumes
Message by batch. |
ConsumerFactory |
ConsumerPolicy
The consumer policy drive the consumer pool and runner.
|
ConsumerPolicy.Builder |
ConsumerPolicy.StartOffset |
ConsumerPool
Run a pool of ConsumerRunner.
|
ConsumerStatus
The return status of a
ConsumerRunner |
Class and Description |
---|
AbstractCallablePool
Execute a pool of callables.
|
Copyright © 2017 Nuxeo. All rights reserved.