Is there a built in way to segregate consumer thread pools per channel? I'm trying to solve for a scenario where a single box is consuming from multiple queues, but one of the queues has either long running tasks or a high volume of messages compared to the other queue it's consuming from and would like to process both as equally as possible.
AK On Sunday, December 29, 2013 3:17:18 AM UTC-5, Michael Klishin wrote: > > > 2013/12/29 Marc Limotte <msli...@gmail.com <javascript:>> > >> 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 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.
