I also have prefetch set to 1, as per question 1 in the original email. As I understand it, a single channel with prefetch 1 will only process 1 message at a time, even if there are multiple threads in the pool. Message processing in my case is long running and I prefer distribution across nodes over distribution across threads on the same node.
marc On Sun, Dec 29, 2013 at 3:17 AM, Michael Klishin < michael.s.klis...@gmail.com> wrote: > > 2013/12/29 Marc Limotte <mslimo...@gmail.com> > >> I was able to get this working using a fixed thread pool executor >> supplied to the connection. Something like this: >> >> (import java.util.concurrent.Executors) >> (mq/connect :executor (Executors/newFixedThreadPool n)) >> >> >> Where n is the number of threads. You will also want to subscribe n >> channels. >> > > Using multiple channels is not really necessary. All consumer work pools > will share the executor > regardless of the number of channels. > -- > MK > > http://github.com/michaelklishin > http://twitter.com/michaelklishin > > -- > You received this message because you are subscribed to a topic in the > Google Groups "clojure-rabbitmq" group. > To unsubscribe from this topic, visit > https://groups.google.com/d/topic/clojure-rabbitmq/TxonGAQAr9Q/unsubscribe > . > To unsubscribe from this group and all its topics, send an email to > clojure-rabbitmq+unsubscr...@googlegroups.com. > For more options, visit https://groups.google.com/groups/opt_out. > -- You received this message because you are subscribed to the Google Groups "clojure-rabbitmq" group. To unsubscribe from this group and stop receiving emails from it, send an email to clojure-rabbitmq+unsubscr...@googlegroups.com. For more options, visit https://groups.google.com/groups/opt_out.
