0

メッセージを同時に消費したいキューがあり、これらのメッセージを 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)

        }
    }

それは並行して実行されますか??

4

1 に答える 1