If I use akka-camel to do it , sample code as below.* If I set
concurrentConsumers=100 then Will it stilluse 100 threads to pull messages
off the queue and execute your route in parallel??*
public class AkkaConsumerActor extends UntypedConsumerActor {
private static final Logger logger = Loggers.getLogger();
public String getEndpointUri() {
return "seda:trades?size=1000000&*concurrentConsumers=20*";
}
public void onReceive(Object message) {
logger.info("thread id: " + Thread.currentThread().getId());
}
}
--
View this message in context:
http://camel.465427.n5.nabble.com/question-about-seda-component-tp5752720p5752723.html
Sent from the Camel - Users mailing list archive at Nabble.com.
