[ https://issues.jboss.org/browse/DROOLS-1228?page=com.atlassian.jira.plugi... ] Mario Fusco closed DROOLS-1228. ------------------------------- Resolution: Cannot Reproduce Bug I tried to reproduce what you described with the test case I'm pasting below, but it works for me. If you're still having this issue please create a complete reproducer (maybe reusing part of what I did) attach it to this ticket and reopen the ticket. {code} @Test public void testUpdateDuringFireUntilHalt() throws Exception { String drl = "import " + AtomicInteger.class.getCanonicalName() + ";\n" + "import " + BlockingQueue.class.getCanonicalName() + ";\n" + "global BlockingQueue queue;\n" + "rule R1 when\n" + " $i: Integer(this > 0) \n" + "then " + " delete($i);" + "end\n" + "rule R2 when\n" + " $i: AtomicInteger(get() == 0 || get() == 2) \n" + "then " + " modify($i) { set( $i.get() + 1 ) };" + " queue.put($i);" + "end\n"; final KieSession ksession = new KieHelper().addContent( drl, ResourceType.DRL ) .build() .newKieSession(); BlockingQueue<AtomicInteger> queue = new LinkedBlockingQueue<AtomicInteger>(); ksession.setGlobal("queue", queue); new Thread () { public void run () { ksession.fireUntilHalt(); } }.start(); new Thread () { public void run () { // keep the engine busy for (int i = 1; i < 1000000; i++) { ksession.insert( i ); } } }.start(); AtomicInteger obj = new AtomicInteger(0); FactHandle fh = ksession.insert( obj ); for (int i = 0; i < 2; i++) { AtomicInteger aInt = queue.take(); if (aInt.get() % 2 == 0) { fail(aInt + " should be odd"); } aInt.set(aInt.get()+1); ksession.update( fh, aInt ); } ksession.halt(); assertEquals( 4, obj.get() ); } {code} -- This message was sent by Atlassian JIRA (v6.4.11#64026)