[jboss-jira] [JBoss JIRA] (DROOLS-1227) Drools cannot be configured to expire Events properly

[ https://issues.jboss.org/browse/DROOLS-1227?page=com.atlassian.jira.plugi... ] Jochen Welle commented on DROOLS-1227: -------------------------------------- Sorry, I cannot attach the test. Follows inline: {code:java} package testpackage; import static org.junit.Assert.assertEquals; import java.util.concurrent.TimeUnit; import org.drools.core.ClockType; import org.drools.core.time.SessionPseudoClock; import org.junit.Before; import org.junit.Test; import org.kie.api.KieBase; import org.kie.api.KieServices; import org.kie.api.builder.KieBuilder; import org.kie.api.builder.KieFileSystem; import org.kie.api.builder.Message; import org.kie.api.builder.model.KieBaseModel; import org.kie.api.builder.model.KieModuleModel; import org.kie.api.builder.model.KieSessionModel; import org.kie.api.conf.EventProcessingOption; import org.kie.api.definition.type.FactType; import org.kie.api.runtime.KieContainer; import org.kie.api.runtime.KieSession; import org.kie.api.runtime.conf.ClockTypeOption; public class ExpirationTest { KieContainer kieContainer; @Before public void setup() { KieServices kieServices = KieServices.Factory.get(); // create KieModule programmatically (instead of using kmodule.xml): KieModuleModel kieModuleModel = kieServices.newKieModuleModel(); KieBaseModel kieBaseModel1 = kieModuleModel.newKieBaseModel( "KBase1 ") .setDefault( true ) .setEventProcessingMode( EventProcessingOption.STREAM ); //.setEqualsBehavior( EqualityBehaviorOption.EQUALITY ) KieSessionModel ksessionModel1 = kieBaseModel1.newKieSessionModel( "KSession1" ) .setDefault( true ) .setType( KieSessionModel.KieSessionType.STATEFUL ) .setClockType( ClockTypeOption.get(ClockType.PSEUDO_CLOCK.toString()) ); // add KModuleXML to KieFileSystem: KieFileSystem kfs = kieServices.newKieFileSystem(); kfs.writeKModuleXML(kieModuleModel.toXML()); String str = "package testpackage\n" + "declare BuyOrderEvent\n" + "@role(event)\n" + " id : int\n" + "end\n" + "declare AckEvent\n" + "@role(event)\n" + " id : int\n" + "end\n" + "rule \"correlate orders\"\n" + "when\n" + " $bo : BuyOrderEvent( $id : id ) \n" + " $ae : AckEvent( id == $id, this after[0,10s] $bo )\n" + "then\n" + " System.out.println(\"buy and ack correlated\");\n" + "end\n"; kfs.write("src/main/resources/testpackage/testExpiration.drl", str); KieBuilder kieBuilder = kieServices.newKieBuilder( kfs ).buildAll(); // build KieModule and add it to the KieRepository (Singleton) assertEquals( 0, kieBuilder.getResults().getMessages( Message.Level.ERROR ).size() ); // If a release id is not defined (with KieFileSystem.writePomXML()) the default release id is used: assertEquals(kieServices.getRepository().getDefaultReleaseId(), kieBuilder.getKieModule().getReleaseId()); kieContainer = kieServices.newKieContainer(kieBuilder.getKieModule().getReleaseId()); } @Test public void testBuyAck() throws Exception { KieBase kieBase = kieContainer.getKieBase(); KieSession kieSession = kieContainer.newKieSession(); SessionPseudoClock clock = kieSession.getSessionClock(); FactType buyType = kieBase.getFactType("testpackage", "BuyOrderEvent"); FactType ackType = kieBase.getFactType("testpackage", "AckEvent"); Object buy = buyType.newInstance(); buyType.set(buy, "id", 1); Object ack = ackType.newInstance(); ackType.set(ack, "id", 1); kieSession.insert(buy); kieSession.insert(ack); assertEquals(2, kieSession.getFactCount()); // we have two facts inserted kieSession.fireAllRules(); clock.advanceTime(11, TimeUnit.SECONDS); kieSession.fireAllRules(); for (Object fh : kieSession.getFactHandles()) { System.out.println(fh.toString()); } // BuyOrderEvent is removed but AckEvent not, according to documentation both should be removed. assertEquals(0, kieSession.getFactCount()); kieSession.dispose(); } @Test public void testAcks() throws Exception { KieBase kieBase = kieContainer.getKieBase(); KieSession kieSession = kieContainer.newKieSession(); SessionPseudoClock clock = kieSession.getSessionClock(); FactType ackType = kieBase.getFactType("testpackage", "AckEvent"); Object ack = ackType.newInstance(); ackType.set(ack, "id", 42); kieSession.insert(ack); clock.advanceTime(1, TimeUnit.MILLISECONDS); kieSession.fireAllRules(); for (Object fh : kieSession.getFactHandles()) { System.out.println(fh.toString()); } clock.advanceTime(11, TimeUnit.SECONDS); kieSession.fireAllRules(); for (Object fh : kieSession.getFactHandles()) { System.out.println(fh.toString()); } assertEquals(0, kieSession.getFactCount()); kieSession.dispose(); } } {code} -- This message was sent by Atlassian JIRA (v7.2.3#72005)