【java – 配置Spring Integration聚合器以组合RabbitMq扇出交换的响应】教程文章相关的互联网学习教程文章

java – 配置Spring Integration聚合器以组合RabbitMq扇出交换的响应【代码】

我试图使用Spring Integration配置以下内容: >向频道发送消息.>将此消息发布到与n个消费者的兔子扇出(pub / sub)交换.>每个消费者都提供响应消息.>让Spring Integration在将它们返回到原始客户端之前聚合这些响应. 到目前为止,我有一些问题…… >我正在使用发布 – 订阅 – 通道来设置apply-sequence =“true”属性,以便correlationId,sequenceSize& sequenceNumber属性已设置. DefaultAmqpHeaderMapper抛弃了这些属性. DEBUG hea...