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

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

Related Packages

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

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