Package org.nuxeo.lib.stream.pattern.consumer

package org.nuxeo.lib.stream.pattern.consumer

Related Packages

Package	Description
org.nuxeo.lib.stream.pattern	Here is a producer consumer pattern that relies on Log.
org.nuxeo.lib.stream.pattern.consumer.internals
org.nuxeo.lib.stream.pattern.producer

Class	Description
AbstractConsumer<M extends Message>
BatchPolicy	Describe when a batch must be flushed.
BatchPolicy.Builder
Consumer<M extends Message>	A consumer consumes Message by batch.
ConsumerFactory<M extends Message>
ConsumerPolicy	The consumer policy drive the consumer pool and runner.
ConsumerPolicy.StartOffset
ConsumerPolicyBuilder
ConsumerPool<M extends Message>	Run a pool of ConsumerRunner.
ConsumerStatus	The return status of a ConsumerRunner