Uses of Interface
org.nuxeo.lib.stream.pattern.consumer.ConsumerFactory

Packages that use ConsumerFactory

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

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

Classes in org.nuxeo.importer.stream.consumer that implement ConsumerFactory

Modifier and Type	Class	Description
class	BlobMessageConsumerFactory
class	DocumentMessageConsumerFactory
class	RedisDocumentMessageConsumerFactory

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

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 ConsumerFactory in org.nuxeo.lib.stream.pattern.consumer

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

Modifier and Type	Field	Description
protected ConsumerFactory<M>	ConsumerPool.factory

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

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 ConsumerFactory in org.nuxeo.lib.stream.pattern.consumer.internals

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

Modifier and Type	Field	Description
protected ConsumerFactory<M>	ConsumerRunner.factory

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

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)