彈簧集成 - 處理2個不同聚合的消息

Question

我使用彈簧集成連接到TCP套接字。我在出站網關上發送2個不同的消息，它返回相同的輸出，即頭部和有效載荷。

現在我想要以不同的方式處理回覆消息，然後聚合成單個消息，然後可以由主服務類處理。

我試過各種技術，但沒有任何工作。

這樣做是否可行？如果是的話，請幫助我。

Answer 1

您需要將消息關聯起來，可能是標頭（例如標準相關標識）。

使用header-richher在每個出站消息上設置相關標識頭。通過簡單的發佈策略（release-strategy-expression="size() == 2"）將回復消息發送到<aggregator />。當收到第二個回覆時，將發佈一個帶有有效載荷的消息（2個有效載荷的集合）。