<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<html>
<body link="#355491" alink="#4262a1" vlink="#355491" style="background: #e2e2e2; margin: 0; padding: 20px;">
<div>
<table cellpadding="0" bgcolor="#FFFFFF" border="0" cellspacing="0" style="border: 1px solid #dadada; margin-bottom: 30px; width: 100%; -moz-border-radius: 6px; -webkit-border-radius: 6px;">
<tbody>
<tr>
<td>
<table border="0" cellpadding="0" cellspacing="0" bgcolor="#FFFFFF" style="border: solid 2px #ccc; background: #dadada; width: 100%; -moz-border-radius: 6px; -webkit-border-radius: 6px;">
<tbody>
<tr>
<td bgcolor="#000000" valign="middle" height="58px" style="border-bottom: 1px solid #ccc; padding: 20px; -moz-border-radius-topleft: 3px; -moz-border-radius-topright: 3px; -webkit-border-top-right-radius: 5px; -webkit-border-top-left-radius: 5px;">
<h1 style="color: #333333; font: bold 22px Arial, Helvetica, sans-serif; margin: 0; display: block !important;">
<!-- To have a header image/logo replace the name below with your img tag -->
<!-- Email clients will render the images when the message is read so any image -->
<!-- must be made available on a public server, so that all recipients can load the image. -->
<a href="http://community.jboss.org/index.jspa" style="text-decoration: none; color: #E1E1E1">JBoss Community</a></h1>
</td>
</tr>
<tr>
<td bgcolor="#FFFFFF" style="font: normal 12px Arial, Helvetica, sans-serif; color:#333333; padding: 20px; -moz-border-radius-bottomleft: 4px; -moz-border-radius-bottomright: 4px; -webkit-border-bottom-right-radius: 5px; -webkit-border-bottom-left-radius: 5px;"><h3 style="margin: 10px 0 5px; font-size: 17px; font-weight: normal;">
jBPM issue using Persistence and fireUntilHalt
</h3>
<span style="margin-bottom: 10px;">
created by <a href="http://community.jboss.org/people/bezudar">Abhishek Chavan</a> in <i>jBPM</i> - <a href="http://community.jboss.org/message/625191#625191">View the full discussion</a>
</span>
<hr style="margin: 20px 0; border: none; background-color: #dadada; height: 1px;">
<div class="jive-rendered-content"><p>Hi,</p><p>I am trying to use the jBPM example for persisting the data and trying to use another thread for rule processing using </p><pre class="jive-pre"><code class="jive-code jive-java">ksession.fireUntilHalt();
</code></pre><p>but I am encountering the following exception.</p><pre class="jive-pre"><code class="jive-code jive-java">Exception in thread <font color="red">"Thread-4"</font> org.drools.RuntimeDroolsException: Unexpected exception executing action org.jbpm.process.instance.event.DefaultSignalManager$SignalAction@1be20c
    at org.drools.common.AbstractWorkingMemory.executeQueuedActions(AbstractWorkingMemory.java:996)
    at org.drools.common.DefaultAgenda.fireUntilHalt(DefaultAgenda.java:1037)
    at org.drools.common.AbstractWorkingMemory.fireUntilHalt(AbstractWorkingMemory.java:777)
    at org.drools.common.AbstractWorkingMemory.fireUntilHalt(AbstractWorkingMemory.java:753)
    at org.drools.command.runtime.rule.FireUntilHaltCommand$1.run(FireUntilHaltCommand.java:50)
    at java.lang.Thread.run(Unknown Source)
Caused by: java.lang.NullPointerException
    at org.drools.persistence.jpa.processinstance.JPAWorkItemManager.internalExecuteWorkItem(JPAWorkItemManager.java:43)
    at org.jbpm.workflow.instance.node.WorkItemNodeInstance.internalTrigger(WorkItemNodeInstance.java:106)
    at org.jbpm.workflow.instance.impl.NodeInstanceImpl.trigger(NodeInstanceImpl.java:122)
    at org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerConnection(NodeInstanceImpl.java:186)
    at org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerCompleted(NodeInstanceImpl.java:150)
    at org.jbpm.workflow.instance.impl.ExtendedNodeInstanceImpl.triggerCompleted(ExtendedNodeInstanceImpl.java:47)
    at org.jbpm.workflow.instance.node.StateBasedNodeInstance.triggerCompleted(StateBasedNodeInstance.java:162)
    at org.jbpm.workflow.instance.node.StateBasedNodeInstance.triggerCompleted(StateBasedNodeInstance.java:143)
    at org.jbpm.workflow.instance.node.RuleSetNodeInstance.signalEvent(RuleSetNodeInstance.java:73)
    at org.jbpm.workflow.instance.impl.WorkflowProcessInstanceImpl.signalEvent(WorkflowProcessInstanceImpl.java:339)
    at org.jbpm.process.instance.event.DefaultSignalManager.internalSignalEvent(DefaultSignalManager.java:80)
    at org.jbpm.process.instance.event.DefaultSignalManager$SignalAction.execute(DefaultSignalManager.java:175)
    at org.drools.common.AbstractWorkingMemory.executeQueuedActions(AbstractWorkingMemory.java:994)
    ... 5 more
</code></pre><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>The same is working fine without persistence and another test is running fine with persistence but there i am calling </p><pre class="jive-pre"><code class="jive-code jive-java">kession.fireAllRules();
</code></pre><p> explicitly. I have made my model classes serializable.</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>The code used is :</p><pre class="jive-pre"><code class="jive-code jive-java"><font color="navy"><b>public</b></font> <font color="navy"><b>void</b></font> reactiveProcessAndRulesTest() <font color="navy"><b>throws</b></font> InterruptedException <font color="navy">{</font>
        KnowledgeBuilder kbuilder = KnowledgeBuilderFactory
                .newKnowledgeBuilder();
        kbuilder.add(<font color="navy"><b>new</b></font> ClassPathResource(<font color="red">"EmergencyServiceSimple.bpmn"</font>),
                ResourceType.BPMN2);
        kbuilder.add(<font color="navy"><b>new</b></font> ClassPathResource(<font color="red">"SelectEmergencyVehicleSimple.drl"</font>),
                ResourceType.DRL);
        KnowledgeBuilderErrors errors = kbuilder.getErrors();
        <font color="navy"><b>if</b></font> (errors.size() > 0) <font color="navy">{</font>
            <font color="navy"><b>for</b></font> (KnowledgeBuilderError error : errors) <font color="navy">{</font>
                System.out.println(error.getMessage());
 
            <font color="navy">}</font>
            <font color="navy"><b>return</b></font>;
        <font color="navy">}</font>
 
        KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
        kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
 
        EntityManagerFactory emf = Persistence
                .createEntityManagerFactory(<font color="red">"org.jbpm.task"</font>);
        Environment env = KnowledgeBaseFactory.newEnvironment();
        env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, emf);
 
        <font color="navy"><b>final</b></font> StatefulKnowledgeSession ksession = JPAKnowledgeService
                .newStatefulKnowledgeSession(kbase, null, env);
<font color="darkgreen">//         ksession = kbase.newStatefulKnowledgeSession();</font>
 
        <font color="darkgreen">// Setting the process engine and the rule engine in reactive mode</font>
        <font color="darkgreen">// This will cause that if a rule is activated, the rule will fire</font>
        <font color="darkgreen">// without waiting</font>
        <font color="darkgreen">// the user to call the fireAllRules() method.</font>
       
 
        MyHumanChangingValuesSimulatorWorkItemHandler humanActivitiesSimHandler = <font color="navy"><b>new</b></font> MyHumanChangingValuesSimulatorWorkItemHandler();
        ksession.getWorkItemManager().registerWorkItemHandler(<font color="red">"Human Task"</font>,
                humanActivitiesSimHandler);
 
        KnowledgeRuntimeLoggerFactory.newConsoleLogger(ksession);
 
        Emergency emergency = <font color="navy"><b>new</b></font> Emergency(<font color="red">"555-1234"</font>);
        <font color="darkgreen">// Run with Heart Attack and check the output. An Ambulance must appear</font>
        <font color="darkgreen">// in the report</font>
        <font color="darkgreen">// emergency.setType("Heart Attack");</font>
        <font color="darkgreen">// Run with Fire and check the output. A FireTruck must appear in the</font>
        <font color="darkgreen">// report</font>
        emergency.setType(<font color="red">"Fire"</font>);
        Map<String, Object> parameters = <font color="navy"><b>new</b></font> HashMap<String, Object>();
        parameters.put(<font color="red">"emergency"</font>, emergency);
 
        WorkflowProcessInstance process = (WorkflowProcessInstance) ksession
                .startProcess(
                        <font color="red">"com.wordpress.salaboy.bpmn2.SimpleEmergencyService"</font>,
                        parameters);
        <font color="darkgreen">// My Emergency and My Process are both inserted as Facts / Truths in my</font>
        <font color="darkgreen">// Knowledge Session</font>
        <font color="darkgreen">// Now Emergency and the Process Instance can be used by the inference</font>
        <font color="darkgreen">// engine</font>
        ksession.insert(emergency);
        ksession.insert(process);
       
        <font color="navy"><b>new</b></font> Thread(<font color="navy"><b>new</b></font> Runnable() <font color="navy">{</font>
 
            <font color="navy"><b>public</b></font> <font color="navy"><b>void</b></font> run() <font color="navy">{</font>
               
                ksession.fireUntilHalt();
            <font color="navy">}</font>
        <font color="navy">}</font>).start();
 
        <font color="darkgreen">// Is the Process still Active?</font>
        Assert.assertEquals(ProcessInstance.STATE_ACTIVE, process.getState());
        <font color="darkgreen">// Is there a running node instance?</font>
        Assert.assertEquals(1, process.getNodeInstances().size());
        <font color="darkgreen">// Is the process stopped in the "Ask for Emergency Information"</font>
        <font color="darkgreen">// activity?</font>
        Assert.assertEquals(<font color="red">"Ask for Emergency Information"</font>, process
                .getNodeInstances().iterator().next().getNodeName());
        <font color="darkgreen">// Lets check the value of the emergency.getRevision(), it should be 1</font>
        Assert.assertEquals(1,
                ((Emergency) process.getVariable(<font color="red">"emergency"</font>)).getRevision());
 
        System.out.println(<font color="red">"Completing the first Activity"</font>);
        <font color="darkgreen">// Complete the first human activity</font>
        humanActivitiesSimHandler.completeWorkItem();
 
        <font color="darkgreen">// I need to sleep for a little while, because the other thread can be</font>
        <font color="darkgreen">// executing some activated rules</font>
        Thread.sleep(1000);
 
        <font color="darkgreen">// Lets check the value of the vehicle variable it should be a Fire</font>
        <font color="darkgreen">// Truck => Fire</font>
        Assert.assertTrue(((Vehicle) process.getVariable(<font color="red">"vehicle"</font>)) <font color="navy"><b>instanceof</b></font> FireTruck);
 
        <font color="darkgreen">// Is the Process still Active?</font>
        Assert.assertEquals(ProcessInstance.STATE_ACTIVE, process.getState());
        <font color="darkgreen">// Is there a running node instance?</font>
        Assert.assertEquals(1, process.getNodeInstances().size());
        <font color="darkgreen">// Is the process stopped in the "Dispatch Vehicle" activity?</font>
        Assert.assertEquals(<font color="red">"Dispatch Vehicle"</font>, process.getNodeInstances()
                .iterator().next().getNodeName());
        <font color="darkgreen">// Lets check the value of the emergency.getRevision(), it should be 2</font>
        Assert.assertEquals(2,
                ((Emergency) process.getVariable(<font color="red">"emergency"</font>)).getRevision());
 
        System.out.println(<font color="red">"Completing the second Activity"</font>);
        <font color="darkgreen">// Complete the second human activity</font>
        humanActivitiesSimHandler.completeWorkItem();
 
        <font color="darkgreen">// Is the process completed?</font>
        Assert.assertEquals(ProcessInstance.STATE_COMPLETED, process.getState());
    <font color="navy">}</font>
 
 
</code></pre><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>My Full code is in this thread : <a class="" href="http://community.jboss.org/message/625081#625081">http://community.jboss.org/message/625081</a></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>Any help would be appreciated. </p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>I also see very wierd behaviour happening when running the program in Debug mode in eclipse and run mode. </p></div>
<div style="background-color: #f4f4f4; padding: 10px; margin-top: 20px;">
<p style="margin: 0;">Reply to this message by <a href="http://community.jboss.org/message/625191#625191">going to Community</a></p>
<p style="margin: 0;">Start a new discussion in jBPM at <a href="http://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2034">Community</a></p>
</div></td>
</tr>
</tbody>
</table>
</td>
</tr>
</tbody>
</table>
</div>
</body>
</html>