メッセージを同時に消費したいキューがあり、これらのメッセージを org.apache.camel.Processor を実装して MyProcessor に渡します。MyProcessor も並行して実行したいです。MyProcessor が reantrantlock で runnable を呼び出すことに注意してください。
from(activemq:Myqueue?maxConcurrentConsumers=10)
.process(new MyProcessor());
class MyProcessor implements org.apache.camel.Processor {
@Override
public void process(Exchange exchange) throws Exception {
// Do some process
sleep(1000)
}
}
それは並行して実行されますか??