我正在使用具有并行处理和聚合器的多播。一个多播正在调用多个端点,这些端点也是另一个多播的一部分。
当有重负载应用程序停止响应时,所有线程都进入等待状态。
这是 Camel Spring-Boot 应用程序
from(ROUTE1)
.multicast(new RROUTE1_Aggregator())
.parallelProcessing()
.executorService(Executors.newFixedThreadPool(size,new ThreadFactoryBuilder().setNameFormat(ROUE1!+"-%d").build()))
.to(ROUTE2)
.to(ROUTE3)
.to(ROUTE4)
.to(ROUTE5)
.to(ROUTE6)
.end()
.process(processResponse)
.end();
from(ROUTE2)
.multicast(new RROUTE2_Aggregator())
.parallelProcessing()
.executorService(Executors.newFixedThreadPool(size,new ThreadFactoryBuilder().setNameFormat(ROUE2!+"-%d").build()))
.to(ROUTE7)
.to(ROUTE8)
.to(ROUTE9)
.to(ROUTE10)
.end()
.process(processResponse)
.end();