According to your description, you have to use a configuration based on the PublishSubscribeChannel (Auction) with a TaskExecutor provided. The subscribers to this channel could be plain HTTP message handler, service activator or even transformers to manipulate a payload before target service call.
发布评论
评论(1)
因此,要对相同的有效载荷进行3个并行呼叫,然后汇总结果,您需要研究一个散点图: https://docs.spring.io/spring-integration/docs/docs/current/current/current/referent/referent/reference/html/html/message-routing.html #散点机。
根据您的描述,您必须使用基于
PublishSubscribechannel
(拍卖)的配置,并提供taskexecutor
提供的配置。此通道的订阅者可以是普通的HTTP消息处理程序,服务激活程序,甚至是变压器,以在目标服务调用之前操纵有效负载。So, to make a 3 parallel calls for the same payload and then aggregate their result, you need to look into a Scatter-Gather pattern: https://docs.spring.io/spring-integration/docs/current/reference/html/message-routing.html#scatter-gather.
According to your description, you have to use a configuration based on the
PublishSubscribeChannel
(Auction) with aTaskExecutor
provided. The subscribers to this channel could be plain HTTP message handler, service activator or even transformers to manipulate a payload before target service call.