Uses of Class
org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy
Package
Description
-
Uses of ConsumerPolicy in org.nuxeo.importer.stream.consumer
ModifierConstructorDescriptionDocumentConsumerPool
(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
Modifier 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
ModifierConstructorDescriptionConsumerPool
(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
ModifierConstructorDescriptionConsumerRunner
(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
.