Class ConsumerPool<M extends Message>