Uses of Interface
org.nuxeo.lib.stream.pattern.consumer.ConsumerFactory
Packages that use ConsumerFactory
Package
Description
-
Uses of ConsumerFactory in org.nuxeo.importer.stream.consumer
Classes in org.nuxeo.importer.stream.consumer that implement ConsumerFactoryModifier and TypeClassDescriptionclass
class
Constructors in org.nuxeo.importer.stream.consumer with parameters of type ConsumerFactoryModifierConstructorDescriptionDocumentConsumerPool
(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 ConsumerFactory in org.nuxeo.lib.stream.pattern.consumer
Fields in org.nuxeo.lib.stream.pattern.consumer declared as ConsumerFactoryConstructors in org.nuxeo.lib.stream.pattern.consumer with parameters of type ConsumerFactoryModifierConstructorDescriptionConsumerPool
(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 ConsumerFactory in org.nuxeo.lib.stream.pattern.consumer.internals
Fields in org.nuxeo.lib.stream.pattern.consumer.internals declared as ConsumerFactoryConstructors in org.nuxeo.lib.stream.pattern.consumer.internals with parameters of type ConsumerFactoryModifierConstructorDescriptionConsumerRunner
(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
.