2014-02-19 21 views
0

我的項目的要求實施的,我一直在建議使用用戶埃斯佩爾CEP引擎。但是,在閱讀Esper的一些文檔後,我不認爲這適合我的使用案例。任何人都可以解釋如何根據以下要求使用Esper? - 存在一個應用程序隊列 - 啓動器應用程序將JMS消息發送到下一個系統/應用程序,並將其發送到下一個系統。這一直持續到最後的系統,最終發送穿過反向路徑的ack直到發起者系統。 - 將消息發送到隊列中的下一個系統時,每個系統都會將消息的副本發送給我的應用程序。同樣,我的系統也會以退貨方式收到每個系統的ack副本。 - 來自系統的每條消息與其先前系統生成的消息相關,所以是ack。 - 我的系統的要求是使用消息中的鏈接信息鏈接所有這些消息和他們的消息,並查找是否有消息丟失或未收到。 - 同樣可以有成千上萬的系統 接收源的消息和其相關的消息 - 每個消息的層次結構都有一個唯一的ID - 我的系統可以以任意順序接收消息/序列請問我的使用情況下,使用艾斯波CEP

任何人可以幫助我瞭解如何使用Esper鏈接消息並在每個消息層次結構中找到缺少的消息?

回答

1

是Esper可以很容易地檢測事件的缺失,例如通過模式或外連接,或者存在異常流。樣品可以在http://esper.codehaus.org/tutorials/solution_patterns/solution_patterns.html

+0

感謝本作中找到。我通過鏈接。但是,不確定我是否缺少某些東西,但我仍然沒有發現CEP方法對我的用例非常有用。在我的要求中,一個訂單消息可以跟着n個填充消息。可以有數百萬個訂單,每個訂單都有一個uniqueId。另外,每個訂單消息都有多個相關的訂單消息。我將如何跟蹤缺失的訂單或填寫每個訂單層次結構? – prasadsh