Hello,<div><br></div><div>I am trying to use rabbitMQ to rebuild complete index's from a database with 800,000+ entries to new databases that stores the data differently.</div><div>My goal is to have&nbsp;</div><div><ul><li>1 Producer that sends msgs to the queue.<br></li><li>A fixed number of consumers to process the&nbsp;messages&nbsp;from the queue.<br></li><li>Make new consumers to replace any consumers that&nbsp;prematurely&nbsp;die.<br></li></ul></div><div><br></div><div>I did some research and wanted to use <a href="http://docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/Executors.html#newFixedThreadPool(int)">newFixedThreadPool </a>from the Executers Class but I am not sure how to go about it,</div><div>or if it is possible to use with rabbitMQ.</div><div><br></div><div>in my experiment so far I start things like so</div><div><div>&nbsp; &nbsp; &nbsp;</div><div>// create the consumers thread pool</div><div>ExecutorService execSvc = Executors.newFixedThreadPool(4);</div><div><br></div><div>// give the thread pool some consumers</div><div>for (int i = 0; i &lt; 4; i++) {</div></div><blockquote style="margin: 0 0 0 40px; border: none; padding: 0px;"><div><div>execSvc.execute(new RebuilderConsumer());</div></div></blockquote>}<div><br></div><div>However when a thread dies no new thread is created.</div>