分布式 WSO2 CEP答案

【问题标题】：Distributed WSO2 CEP分布式 WSO2 CEP
【发布时间】：2014-11-19 18:16:13
【问题描述】：

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

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

CEP 能否使用 JMS 队列而不是主题？这样，哪个节点首先获取事件数据将消耗队列中的消息？ WSO2 CEP 是否支持 JMS 队列？

【问题讨论】：

标签： wso2 distributed complex-event-processing wso2cep

【解决方案1】：

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

创建自定义代理

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

然后使用 CEP 配置该代理，在 wso2cep-2.0.1/repository/conf 创建一个名为“broker.xml”的文件并添加以下 XML： <brokerTypes xmlns="http://wso2.org/carbon/broker"> <brokerType class="<<class reference>>" /> ... </brokerTypes>

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

【讨论】：

wsocep 2.0.0 的定制代理程序会有什么不同吗？我们在当前设置中使用 2.0.0
您好，我已经实现了 Custom Broker 和 Factory，并在 conf.xml 中添加了带有以下条目的 broker.xml。但在此之后，我在第 149 行的 BrokerManagerAdminServer 中得到空点异常。wso2.org/carbon/broker">。请告知
@RajivPatil 我已经改进了答案，您将能够使用 WSO2CEP 2.1.0 来完成这项工作，该版本将在一周内发布。