统计camel并行拆分成功处理的消息数

from("direct:start")
    .split().body()
    .parallelProcessing()
    .to("direct:process")
    .end();

from("direct:process")
    .process(new Processor() {
        public void process(Exchange exchange) throws Exception {
            // 处理消息的逻辑
        }
    });

from("direct:process")
    .process(new Processor() {
        private AtomicInteger successCount = new AtomicInteger(0);

        public void process(Exchange exchange) throws Exception {
            // 处理消息的逻辑

            // 如果成功处理消息，增加成功计数
            successCount.incrementAndGet();
        }

        public void shutdown() {
            // 输出成功处理的消息数
            System.out.println("成功处理的消息数：" + successCount.get());
        }
    });