我无法找到任何示例来帮助我理解我需要在这里做什么，所以我将解释我的问题：
我有一个为 Pivotal 的 Gemfire 产品实现自定义侦听器的 Java Bean。它实现了一个称为 CqListener 的接口，该接口定义了一个方法，如下所示：
public void onEvent(CQEvent evt){
...
}
基本上，当我们在 Gemfire 网格上执行连续查询 (CQ) 时，我们将此 Bean 注册为侦听器，它将接收网格中与我们的查询匹配的任何更改。
例如，执行类似的 CQ
SELECT * FROM /table_name
每当“table_name”表（在 Gemfire 中它被称为区域）中的任何内容发生更改（CRUD）时，都会CQEvent在方法中为我们提供onEvent
我现在要做的是将 Camel 连接起来，将任何东西从底层 CQ 东西路由到自定义路由。无论如何我可以告诉骆驼说“嘿，任何时候打电话给onEvent，把它路由到其他地方”？
我试图路由到的其他地方是 Akka Actor。已经有一个包装 akka 和骆驼的项目（http://doc.akka.io/docs/akka/snapshot/scala/camel.html）但我无法弄清楚这个端点 URI 业务来获取入站 CQ 事件.
我知道我缺少有关 Camel 的概念键，因此非常感谢任何帮助。我已经设法使用 jms 端点来实现这一点，所以我知道它如何适用于众所周知的协议，但我只是想弄清楚如何为自定义协议执行此操作，其中实现从我身上抽象出来（就像CQListener 的情况）