Class DocumentConsumerPool<M extends Message>