I'm evaluating Camel and ran into a test case where messages aren't being
delivered to a component for some reason. Being new to Camel this is
probably a case of my test routes not being set up correctly.
Here is what I have:
<route>
<!-- in stream to allow you to enter some text in the console
-->
<from
uri="stream:in?initialPromptDelay=4000&promptDelay=2000&promptMessage=Enter
the number of messages to generate:"/>
<to uri="bean:orderSvc?method=createOrderMsg"/>
<split parallelProcessing="true">
<!-- Splits received order msg into multiple orders -->
<method bean="orderSvc" method="splitOrders"/>
<to uri="seda:receiveOrderQueue"/>
</split>
</route>
<route>
<from uri="seda:receiveOrderQueue"/>
<to uri="bean:orderSvc?method=a"/>
<to uri="bean:orderSvc?method=b"/>
<to uri="seda:fulfillOrderQueue"/>
</route>
<route>
<from uri="seda:fulfillOrderQueue?concurrentConsumers=5"/>
<to uri="bean:orderSvc?method=fulfillOrder"/>
</route>
-----------------------
The problem is at the last step - orderSvc.fulfillOrder is never called. If
I remove the concurrentConsumers=5, it does get called.
I'd like multiple threads to concurrently fulfill orders. Am I using the
SEDA concurrentConsumers option incorrectly?
--
View this message in context:
http://www.nabble.com/Messages-not-being-delivered-once-SEDA-concurrentConsumers-set-tp23176637p23176637.html
Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.