将WSO2 CEP连接到WSO2 Message Broker的异常

我正在尝试将WSO2 CEP服务器连接到WSO2 Message Broker服务器 .

我创建了一个jndi.properties文件：

connectionfactory.TopicConnectionFactory = amqp://admin:admin@clientid/carbon?brokerlist='tcp://192.168.11.2:5673'
topic.testTopic = testTopic

输入事件适配器：

<?xml version="1.0" encoding="UTF-8"?>
<inputEventAdaptor name="MBJMSInputAdaptor" statistics="enable"
  trace="enable" type="jms" xmlns="http://wso2.org/carbon/eventadaptormanager">
  <property name="java.naming.provider.url">repository/conf/jndi.properties</property>
  <property name="transport.jms.SubscriptionDurable">false</property>
  <property name="java.naming.factory.initial">org.wso2.andes.jndi.PropertiesFileInitialContextFactory</property>
  <property name="transport.jms.ConnectionFactoryJNDIName">TopicConnectionFactory</property>
  <property name="transport.jms.DestinationType">topic</property>
</inputEventAdaptor>

流定义：

<streamDefinitions xmlns="http://wso2.org/carbon/databridge">
  <streamDefinition>
    {
      "name":"testStream",
      "version":"1.0.0",
      "payloadData":[
        {"name":"id","type":"INT"},
        {"name":"name","type":"STRING"}
      ]
    }
  </streamDefinition>
</streamDefinitions>

和一个事件建设者：

<?xml version="1.0" encoding="UTF-8"?>
<eventBuilder name="testBuilder" statistics="enable" trace="enable" xmlns="http://wso2.org/carbon/eventbuilder">
  <from eventAdaptorName="MBJMSInputAdaptor" eventAdaptorType="jms">
    <property name="topic">testTopic</property>
  </from>
  <mapping customMapping="enable" type="json">
    <property>
      <from jsonPath="id"/>
      <to name="id" type="int"/>
    </property>
    <property>
      <from jsonPath="name"/>
      <to name="name" type="string"/>
    </property>
  </mapping>
  <to streamName="testStream" version="1.0.0"/>
</eventBuilder>

遗憾的是，WSO2 CEP服务器不接收来自WSO2 Message Broker服务器的消息，并引发以下异常：

[2014-11-28 13：00：00,226] INFO - JMS输入事件适配器加载侦听器java.util.concurrent.ConcurrentHashMap.hash中的线程“Thread-29”java.lang.NullPointerException中的异常（ConcurrentHashMap . java：333）at java.util.concurrent.ConcurrentHashMap.get（ConcurrentHashMap.java:988）atg.wso2.carbon.event.input.adaptor.jms.JMSEventAdaptorType.createJMSAdaptorListener（JMSEventAdaptorType.java:291）org.wso2 orcarbon.wso2.carbon.event.input.adaptor.jms.internal.ds.JMSEventAdaptorServiceHolder.loadLateStartEventAdaptors . （ . JMSEventAdaptorServiceHolder.java:66 at org.wso2.carbon.event.input.adaptor.jms.internal.ds.JMSEventAdaptorServiceHolder $ 1.run（JMSEventAdaptorServiceHolder.java:43）at java.lang.Thread.run（Thread.java:745）

你能帮我调试这个例外吗？