Re: [rules-users] Implementing Timers With Drools Persistence Enabled

Hi salaboy, Here is an image of my flow: http://drools-java-rules-engine.46999.n3.nabble.com/file/n923330/SnapShot... Here is the flow definition: <?xml version="1.0" encoding="UTF-8"?> <process xmlns="http://drools.org/drools-5.0/process" xmlns:xs="http://www.w3.org/2001/XMLSchema-instance" xs:schemaLocation="http://drools.org/drools-5.0/process drools-processes-5.0.xsd" type="RuleFlow" name="simple-embeded-timer-with-persistence" id="simple-embeded-timer-with-persistence" package-name="com.flow" > <header> </header> <nodes> <start id="1" name="Start" x="16" y="16" width="48" height="48" /> <workItem id="2" name="Suspend With Timer" x="96" y="16" width="144" height="48" > <work name="doNothingHandler" > </work> <timers> <timer id="1" delay="500" period="1000" > <action type="expression" dialect="mvel" >System.out.println("**** Timer Triggered ****");</action> </timer> </timers> </workItem> <actionNode id="3" name="Print Out" x="272" y="20" width="80" height="40" > <action type="expression" dialect="mvel" >System.out.println("**** WorkItem Completed!!! Finishing Flow ****");</action> </actionNode> <end id="4" name="End" x="384" y="20" width="80" height="40" /> </nodes> <connections> <connection from="1" to="2" /> <connection from="2" to="3" /> <connection from="3" to="4" /> </connections> </process> Here is the test code: @Test public void shouldStartFlowAndSuspend() { /* * Persistence enabled - Timer does NOT work!!! */ ksession = JPAKnowledgeService.newStatefulKnowledgeSession(kbase, null, droolsEnvironment); /* * Persistence disabled - Timer DOES work!!! */ //ksession = kbase.newStatefulKnowledgeSession(); sessionId = ksession.getId(); ksession.getWorkItemManager() .registerWorkItemHandler("doNothingHandler", new DoNothingWorkItemHandler()); ksession.startProcess("simple-embeded-timer-with-persistence", null); // start timer thread new Thread() { @Override public void run() { System.out.println("**** Timer thread started ****"); ksession.fireUntilHalt(); } }.start(); // Allow timer to run for 10s try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } } @Test //NOTE: comment out when not using persistence. public void shouldResumeFlowAndComplete() { ksession = JPAKnowledgeService.loadStatefulKnowledgeSession(sessionId, kbase, null, droolsEnvironment); ksession.getWorkItemManager() .registerWorkItemHandler("doNothingHandler", new DoNothingWorkItemHandler()); ksession.getWorkItemManager().completeWorkItem(1, null); } NOTE: when running WITHOUT persistence the second test method for obvious reasons will fail so it needs to be commented out. Persistence is set up correctly, I've checked the database and everything is being persisted. I can as well resume and complete with no problems BUT the timer is NOT working. Let me know if this is enough and/or if you have any question. Thanks, Nick. -- View this message in context: http://drools-java-rules-engine.46999.n3.nabble.com/Implementing-Timers-W... Sent from the Drools - User mailing list archive at Nabble.com.