如何路由自定義Java偵聽器的onEvent使用駱駝

Question

我一直沒能找到幫助我明白我需要做任何的例子，所以我會解釋我的問題：

我有一個Java Bean爲Pivotal的Gemfire產品實現自定義偵聽器。它實現了被稱爲CqListener一個接口，它定義了一個方法如下：

public void onEvent(CQEvent evt){ 
    ... 
} 

基本上，當我們對的GemFire網格執行一個連續查詢（CQ），我們註冊這個bean作爲將接收的任何改變的監聽器在與我們的查詢匹配的網格中。

例如，執行CQ像

SELECT * FROM /table_name 

會給我們一個CQEvent在onEvent方法，只要在「表名」表什麼（在的GemFire這就是所謂的區域雖然）變化（CRUD）

我現在想要做的就是連接駱駝，將任何從這個潛在的CQ東西路由到自定義路由。無論如何，我可以告訴駱駝說：「嘿，任何時候打電話給onEvent，把它放在別的地方」？

我試圖路由到的其他地方是阿卡演員。已經有一個包裹阿卡和駝峯的項目（http://doc.akka.io/docs/akka/snapshot/scala/camel.html），但我無法弄清楚這個Endpoint URI業務是否能夠獲得入站CQ事件。

我知道我錯過了關於駱駝的概念性關鍵，所以任何幫助都非常感謝。我已經設法使用jms端點來實現這個功能，所以我知道它是如何用於衆所周知的協議的，但我只是想弄清楚如何爲自定義協議執行此操作，而將實現從我這裏抽象出來（As is在CQListener的情況下）

Answer 1

我在你的文章中加入了「spring-integration」標籤。來自Spring Integration團隊的人可能會有更多的經驗或想法解決這類問題。

另外，Spring集成的GemFire Suppor文檔和一般的周邊文檔可能會給你更多的想法或選項。