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

Class Summary

Class	Description
AbstractCallablePool<T>	Execute a pool of callables.
BatchState	Keep state of a batch according to a batch policy.
ConsumerRunner<M extends Message>	Read messages from a tailer and drive a consumer according to its policy.

Enum Summary

Enum	Description
BatchState.State