Class ProducerPool<M extends Message>