| Package | Description |
|---|---|
| org.nuxeo.importer.stream.consumer | |
| org.nuxeo.lib.stream.pattern.consumer | |
| org.nuxeo.lib.stream.pattern.consumer.internals |
| Modifier and Type | Class and Description |
|---|---|
class |
BlobMessageConsumerFactory |
class |
DocumentMessageConsumerFactory |
class |
RedisDocumentMessageConsumerFactory |
| Constructor and Description |
|---|
DocumentConsumerPool(String logName,
LogManager manager,
ConsumerFactory<M> factory,
ConsumerPolicy consumerPolicy) |
| Modifier and Type | Field and Description |
|---|---|
protected ConsumerFactory<M> |
ConsumerPool.factory |
| Constructor and Description |
|---|
ConsumerPool(String logName,
LogManager manager,
ConsumerFactory<M> factory,
ConsumerPolicy policy) |
| Modifier and Type | Field and Description |
|---|---|
protected ConsumerFactory<M> |
ConsumerRunner.factory |
| Constructor and Description |
|---|
ConsumerRunner(ConsumerFactory<M> factory,
ConsumerPolicy policy,
LogManager manager,
List<LogPartition> defaultAssignments) |
Copyright © 2019 Nuxeo. All rights reserved.