Class ConsumerPool<M extends Message>

All Implemented Interfaces:
AutoCloseable
Direct Known Subclasses:
DocumentConsumerPool

public class ConsumerPool<M extends Message> extends AbstractCallablePool<ConsumerStatus>
Run a pool of ConsumerRunner.
Since:
9.1