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