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	Description
class	DocumentConsumerPolicy

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

Constructor	Description
DocumentConsumerPool(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)
DocumentConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)	Deprecated. since 11.1, due to serialization issue with java 11, use DocumentConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy) which allows to give a codec to tailer.

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	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	Description
ConsumerPolicy	ConsumerPolicyBuilder.build()

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

Constructor	Description
ConsumerPool(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy policy)
ConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy policy)	Deprecated. since 11.1, due to serialization issue with java 11, use ConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy) which allows to give a codec to tailer.

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	Description
protected ConsumerPolicy	ConsumerRunner.policy

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

Constructor	Description
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, List<LogPartition> defaultAssignments)	Deprecated. since 11.1, due to serialization issue with java 11, use ConsumerRunner(ConsumerFactory, ConsumerPolicy, LogManager, Codec, List) which allows to give a codec to tailer.
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments)