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

Interface Summary

Interface	Description
Consumer<M extends Message>	A consumer consumes Message by batch.
ConsumerFactory<M extends Message>

Class Summary

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

Enum Summary

Enum	Description
ConsumerPolicy.StartOffset