Class | Description |
---|---|
AbstractCallablePool<T> |
Execute a pool of callables.
|
AbstractCallablePool.NamedThreadFactory | |
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 | Description |
---|---|
BatchState.State |
Copyright © 2017 Nuxeo. All rights reserved.