Uses of Class
org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy
Packages that use ConsumerPolicy
Package
Description
-
Uses of ConsumerPolicy in org.nuxeo.importer.stream.consumer
Subclasses of ConsumerPolicy in org.nuxeo.importer.stream.consumerConstructors in org.nuxeo.importer.stream.consumer with parameters of type ConsumerPolicyModifierConstructorDescriptionDocumentConsumerPool
(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy) DocumentConsumerPool
(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy) Deprecated. -
Uses of ConsumerPolicy in org.nuxeo.lib.stream.pattern.consumer
Fields in org.nuxeo.lib.stream.pattern.consumer declared as ConsumerPolicyModifier and TypeFieldDescriptionstatic final ConsumerPolicy
ConsumerPolicy.BOUNDED
Consumer policy that stop on starvation and failure.static final ConsumerPolicy
ConsumerPolicy.BOUNDED_RETRY
protected final ConsumerPolicy
ConsumerPool.policy
static final ConsumerPolicy
ConsumerPolicy.UNBOUNDED
Consumer policy that wait for ever for new message and skip failure.static final ConsumerPolicy
ConsumerPolicy.UNBOUNDED_RETRY
Methods in org.nuxeo.lib.stream.pattern.consumer that return ConsumerPolicyConstructors in org.nuxeo.lib.stream.pattern.consumer with parameters of type ConsumerPolicyModifierConstructorDescriptionConsumerPool
(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, useConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy)
which allows to give acodec
totailer
. -
Uses of ConsumerPolicy in org.nuxeo.lib.stream.pattern.consumer.internals
Fields in org.nuxeo.lib.stream.pattern.consumer.internals declared as ConsumerPolicyConstructors in org.nuxeo.lib.stream.pattern.consumer.internals with parameters of type ConsumerPolicyModifierConstructorDescriptionConsumerRunner
(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, List<LogPartition> defaultAssignments) Deprecated.since 11.1, due to serialization issue with java 11, useConsumerRunner(ConsumerFactory, ConsumerPolicy, LogManager, Codec, List)
which allows to give acodec
totailer
.ConsumerRunner
(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments)
DocumentConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy)
which allows to give acodec
totailer
.