Hi Daniel Yeah if its natural to process the messages out-of-order from the SQS then your patch is on the right track.
Usually if you extend DefaultConsumer, then you can get the async processor using getAsyncProcessor(). An example could be the file consumer https://svn.apache.org/repos/asf/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileConsumer.java And mind this would require that further along some EIP / producer / camel-component supports async processing by nature, to kick in the async routing engine. To have parallel processing of messages. If not, then it will be fully sequential processing using the same thread. Some background details here http://camel.apache.org/asynchronous-processing.html And mind that we love contributions, so patches is welcome http://camel.apache.org/contributing.html On Mon, Mar 19, 2012 at 9:06 PM, dacc <d...@exaptic.com> wrote: > I'm trying to consume multiple exchanges from an SQS endpoint with autoack > disabled, but SqsConsumer blocks on completion of the first one that > arrives. I could have each of my workers poll SQS separately, but this will > increase the number of requests by a factor of the number of workers, which > doesn't seem right. > > This patch to SqsConsumer in 2.8.4 seems to accomplish what I want, but I > don't know if it's safe or the best way to go about things: > > https://gist.github.com/2126164 > > I'm working with a limited understanding of Camel's internals, so hopefully > someone can shed some light. =) > > Thanks, > > - Dan > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Better-Way-to-Achieve-Parallel-Processing-of-SQS-Messages-tp5578135p5578135.html > Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen ----------------- CamelOne 2012 Conference, May 15-16, 2012: http://camelone.com FuseSource Email: cib...@fusesource.com Web: http://fusesource.com Twitter: davsclaus, fusenews Blog: http://davsclaus.blogspot.com/ Author of Camel in Action: http://www.manning.com/ibsen/
