Hi All, I want to read from an JMS queue and run multi threaded a processor on it.
So: From(“activemq:income”).thread(20).process(new MyHardWork()).to(“activemq:outqueue”); As I know this end up in a single threaded route, I need to add a SEDA between the JMS onMessage part and the ThreadPool like: From(“activemq:income”). to(“seda:memqueue”); From(“seda:memqueue”).thread(20).process(new MyHardWork()).to(“activemq:outqueue”); I saw that the SEDA endpoint has an int size = 1000 which can be configured but I don’t like this route config. I want to have more control and I want to use the JmsPollingConsumer which is available in the trunk. I think the ideal solution would be to have an implementation of the ThreadProcessor where we have control over the task queue AND would be able to fetch directly from an JmsPollingConsumer (as long as the task queue is not full). So my question are: 1) Do I miss something? 2) How can I use the JmsPollingConsumer? 3) Does it make sense to implement a different ThreadProcessor to use a polling consumer? 4) What is the best way to implement that? I’d like to do it in a way to be able to contribute the code and make other people happy.. So could you point me to the right direction? I am not sure how to connect a PollingConsumer with a AsyncProcessor… Thanks, Michael -- View this message in context: http://www.nabble.com/Async-JMS-consumer-tp16538660s22882p16538660.html Sent from the Camel - Development mailing list archive at Nabble.com.
