2017-07-18 49 views
0

我有集成項目機智設置如下。彈簧一體化回撥與歡樂同步消息

應用1(Spring集成) - > AMQ - >歡樂 - >互聯網 - >歡樂 - > AMQ - >(Spring集成)應用2

上述流消息正在傳遞發生在兩種方式,我想要實現這樣的事情。

當我從應用程序1發起請求消息(出站)時,它會轉到應用程序2(作爲入站)並將零發送到應用程序1的許多消息(出站)。我的要求是不斷等待所有響應並執行一些操作。

是否有任何功能支持這個在歡樂的春天?

回答

0

聽起來像您需要Application1中的關聯和聚合功能。當您將消息發送到AMQ時,您可以指定一些correlationKey並將此消息發送給聚合器。

然後,您有一個消息驅動通道適配器來偵聽該多答覆的隊列。希望您在發送過程中知道您有多少回覆應該等待。

因此,所有來自回覆的消息都會發送到同一個聚合器,以便與請求進行關聯併爲最終回覆進行分組。所有這些時間你都會被阻塞,等待聚合器輸出通道的結果。

絕對不確定是歡樂如何煮這個解決方案...

+0

感謝比蘭,這將有所幫助。 – Roshan