分布式WSO2 CEP

Question

如果我有一个以JMS代理作为主要输入的分布式CEP设置。

现在，如果我们告诉客户端应用程序将事件发送到主题X，事件将被分发到CEP集群中的每个节点，因为每个节点都将侦听相同的主题X。这是否会导致结果重复(假设我正在计算某个数据字段，现在由于每个节点都在接收重复数据，如果我有一个2节点集群，我的计数是否会是实际值的两倍)

CEP可以在JMS队列中工作而不是在主题中工作吗？这样，哪个节点最先获得事件数据将消耗队列中的消息？JMS是否支持WSO2队列？

Answer 1

不支持，目前(CEP 2.0.1)不支持从JMS队列接收事件。但如果这是您的需求，那么您可以编写自己的CEP addeptor(代理)来从队列接收事件并将其推送到CEP。

创建自定义代理

通过扩展org.wso2.carbon.broker.core.BrokerType来创建适当的代理类型，通过从jar org.wso2.cion.broker.core-4.0.5.jar扩展org.wso2.carbon.broker.core.BrokerTypeFactory来创建适当的代理类型工厂

在http://suhothayan.blogspot.com/2013/02/writing-custom-broker-for-wso2-cep.html上找到有关创建自定义代理的详细文档