1

我希望结合来自两个 Web 服务调用的响应。聚合将基于响应中的键值进行。

ws1,ws2（来自 ws1 和 ws2 的响应被传递给聚合器）--->聚合器--->响应。我返回以下代码。聚合器没有被调用，不确定我错过了什么。

 <int-ws:outbound-gateway id="marshallingGateway1" request-channel="RequestChannel1" reply-channel="replyChannel"
                             uri="https://abc:8080/" message-sender="messageSender"
                             marshaller="marshaller" unmarshaller="marshaller">
        <int-ws:request-handler-advice-chain>
            <ref bean="retryAdvice"/>
        </int-ws:request-handler-advice-chain>
    </int-ws:outbound-gateway>
    <int-ws:outbound-gateway id="marshallingGateway2" request-channel="RequestChannel2" reply-channel="replyChannel"
                             uri="https://abc:8080/" message-sender="messageSender"
                             marshaller="marshaller" unmarshaller="marshaller">
        <int-ws:request-handler-advice-chain>
            <ref bean="retryAdvice"/>
        </int-ws:request-handler-advice-chain>
    </int-ws:outbound-gateway>


    <int:aggregator id="responseAggregator" input-channel="replyChannel" ref="responseAggregator" message-store="messageStore" send-partial-result-on-expiry="true"/>

    <bean id="messageStore" class="org.springframework.integration.store.SimpleMessageStore"/>
    <bean id="responseAggregator" class="abc.cbd.ResponseAggregator"/>
4

1 回答 1

1

您似乎没有在两个结果之间建立任何相关性。

默认情况下，correlationId默认关联策略使用标头。

你还需要一个ReleaseStrategy. 它可以像release-strategy-expression="size == 2".

默认发布策略使用sequenceSize和sequenceNumber标头。

如果您使用发布-订阅通道向两个网关发送相同的消息，请将apply-sequence属性设置为true，然后您就不需要自定义发布或关联策略。

于 2017-03-20T20:41:30.800 回答