<div dir="ltr"><div><div>I am attempting to, using Camel, receive AMQP messages from RabbitMQ and pass them into a Drools Fusion engine.  As my starting point I have a 4 line bit of Java code that instantiates Camel and passes it the camel XML pasted below.  Is it apparent to anyone where I&#39;ve gone wrong that I receive a NPE while the system is calling the init method for &#39;node1&#39;?<br>
<br>&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?&gt;<br><br>&lt;beans xmlns=&quot;<a href="http://www.springframework.org/schema/beans">http://www.springframework.org/schema/beans</a>&quot;<br>       xmlns:xsi=&quot;<a href="http://www.w3.org/2001/XMLSchema-instance">http://www.w3.org/2001/XMLSchema-instance</a>&quot;<br>
       xmlns:rabbit=&quot;<a href="http://www.springframework.org/schema/rabbit">http://www.springframework.org/schema/rabbit</a>&quot;<br>       xmlns:drools=&quot;<a href="http://drools.org/schema/drools-spring">http://drools.org/schema/drools-spring</a>&quot;<br>
       xsi:schemaLocation=&quot;<br>       <a href="http://www.springframework.org/schema/beans">http://www.springframework.org/schema/beans</a> <a href="http://www.springframework.org/schema/beans/spring-beans.xsd">http://www.springframework.org/schema/beans/spring-beans.xsd</a><br>
       <a href="http://www.springframework.org/schema/rabbit">http://www.springframework.org/schema/rabbit</a> <a href="http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd</a><br>
       <a href="http://drools.org/schema/drools-spring">http://drools.org/schema/drools-spring</a> <a href="http://drools.org/schema/drools-spring.xsd">http://drools.org/schema/drools-spring.xsd</a><br>       <a href="http://camel.apache.org/schema/spring">http://camel.apache.org/schema/spring</a> <a href="http://camel.apache.org/schema/spring/camel-spring.xsd">http://camel.apache.org/schema/spring/camel-spring.xsd</a>&quot;&gt;<br>
<br>    &lt;bean id=&quot;droolsPolicy&quot; class=&quot;org.drools.camel.component.DroolsPolicy&quot; /&gt;<br>    &lt;drools:grid-node id=&quot;node1&quot;/&gt;<br>    &lt;drools:kbase id=&quot;kbase1&quot; node=&quot;node1&quot;&gt;<br>
        &lt;drools:configuration&gt;<br>            &lt;drools:mbeans enabled=&quot;true&quot;/&gt;<br>        &lt;/drools:configuration&gt;<br>        &lt;drools:resources&gt;<br>            &lt;drools:resource type=&quot;DRL&quot; source=&quot;classpath:drools-rules.drl&quot;/&gt;<br>
        &lt;/drools:resources&gt;<br>    &lt;/drools:kbase&gt;<br><br>    &lt;drools:ksession id=&quot;ksession1&quot; type=&quot;stateful&quot; name=&quot;ksession1&quot; kbase=&quot;kbase1&quot; node=&quot;node1&quot;/&gt;<br>
<br>    &lt;bean id=&quot;drools&quot; class=&quot;org.drools.camel.component.DroolsComponent&quot;/&gt;<br>    <br>    &lt;bean id=&quot;jsonMessageConverter&quot; class=&quot;amqp.spring.converter.XStreamConverter&quot;/&gt;<br>
    &lt;bean id=&quot;textMessageConverter&quot; class=&quot;amqp.spring.converter.StringConverter&quot;/&gt;<br>    &lt;bean id=&quot;messageConverter&quot; class=&quot;amqp.spring.converter.ContentTypeConverterFactory&quot;&gt;<br>
        &lt;property name=&quot;converters&quot;&gt;<br>            &lt;map&gt;<br>                &lt;entry key=&quot;application/json&quot; value-ref=&quot;jsonMessageConverter&quot;/&gt;<br>                &lt;entry key=&quot;application/xml&quot; value-ref=&quot;textMessageConverter&quot;/&gt;<br>
            &lt;/map&gt;<br>        &lt;/property&gt;<br>        &lt;property name=&quot;fallbackConverter&quot; ref=&quot;textMessageConverter&quot;/&gt;<br>    &lt;/bean&gt;<br>  <br>    &lt;rabbit:connection-factory id=&quot;connectionFactory&quot; host=&quot;127.0.0.1&quot; port=&quot;5672&quot; /&gt;<br>
    &lt;rabbit:template id=&quot;amqpTemplate&quot; connection-factory=&quot;connectionFactory&quot; message-converter=&quot;messageConverter&quot; reply-timeout=&quot;60000&quot;/&gt;<br>    &lt;rabbit:admin connection-factory=&quot;connectionFactory&quot;/&gt;<br>
    <br>    &lt;camelContext xmlns=&quot;<a href="http://camel.apache.org/schema/spring">http://camel.apache.org/schema/spring</a>&quot;&gt;<br>        &lt;route&gt;<br>            &lt;from uri=&quot;stream:in?promptMessage=Enter something: &quot;/&gt;<br>
            &lt;to uri=&quot;spring-amqp:cml.direct:a.b.c?type=direct&quot;/&gt;<br>        &lt;/route&gt;<br>        &lt;route&gt;<br>            &lt;from uri=&quot;spring-amqp:cml.direct:springd:a.b.c?type=direct&quot; /&gt;<br>
            &lt;transform&gt;<br>                &lt;simple&gt;${body.toUpperCase()}&lt;/simple&gt;<br>            &lt;/transform&gt;<br>            &lt;to uri=&quot;spring-amqp:cml.topic:a.b.c&quot;/&gt;<br>        &lt;/route&gt;<br>
        &lt;route&gt;<br>            &lt;from uri=&quot;spring-amqp:cml.topic:springt:#?type=topic&quot; /&gt;<br>            &lt;to uri=&quot;stream:out&quot;/&gt;<br>        &lt;/route&gt;<br>    &lt;/camelContext&gt;<br>
<br>&lt;/beans&gt;<br><br></div>I&#39;m still extremely new to Drools, Camel, BRMS and my ultimate goal is to have BRMS running, receiving events from RabbitMQ.  This is one step along my learning to achieve that goal so any help that can be offered is very much appreciated.<br>
<br></div>It&#39;s potentially worth noting that the JAR files I&#39;m running for this are from the Drools-jBPM Integration 5.5 distribution. <br><div><br>Sincerely,<br>Jason<br></div></div>