Uses of Class
org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy

Packages that use ConsumerPolicy

Package	Description
org.nuxeo.importer.stream.consumer
org.nuxeo.lib.stream.pattern.consumer
org.nuxeo.lib.stream.pattern.consumer.internals

Uses of ConsumerPolicy in org.nuxeo.importer.stream.consumer

Subclasses of ConsumerPolicy in org.nuxeo.importer.stream.consumer

Modifier and Type	Class and Description
class	DocumentConsumerPolicy

Constructors in org.nuxeo.importer.stream.consumer with parameters of type ConsumerPolicy

Constructor and Description
DocumentConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)

Uses of ConsumerPolicy in org.nuxeo.lib.stream.pattern.consumer

Fields in org.nuxeo.lib.stream.pattern.consumer declared as ConsumerPolicy

Modifier and Type	Field and Description
static ConsumerPolicy	ConsumerPolicy.BOUNDED Consumer policy that stop on starvation and failure.
static ConsumerPolicy	ConsumerPolicy.BOUNDED_RETRY
protected ConsumerPolicy	ConsumerPool.policy
static ConsumerPolicy	ConsumerPolicy.UNBOUNDED Consumer policy that wait for ever for new message and skip failure.
static ConsumerPolicy	ConsumerPolicy.UNBOUNDED_RETRY

Methods in org.nuxeo.lib.stream.pattern.consumer that return ConsumerPolicy

Modifier and Type	Method and Description
ConsumerPolicy	ConsumerPolicyBuilder.build()

Constructors in org.nuxeo.lib.stream.pattern.consumer with parameters of type ConsumerPolicy

Constructor and Description
ConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy policy)

Uses of ConsumerPolicy in org.nuxeo.lib.stream.pattern.consumer.internals

Fields in org.nuxeo.lib.stream.pattern.consumer.internals declared as ConsumerPolicy

Modifier and Type	Field and Description
protected ConsumerPolicy	ConsumerRunner.policy

Constructors in org.nuxeo.lib.stream.pattern.consumer.internals with parameters of type ConsumerPolicy

Constructor and Description
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, List<LogPartition> defaultAssignments)