Re: [rules-users] [Drools Fusion] Can't detect 2 occurrences with sliding window

Hello, I'm new to Drools (5.0.1) and i've tryied the following (basic) fusion rule for a few days now without success. The rule is to determine if a user performs 2 operations in the sliding window of 60s. In such a condition, a log message should be triggered. Here is my DRL code : # declare events declare Operation @role(event) @timestamp(date) end rule "overActivity" dialect "mvel" when #condition : 2 operation in less than 1 minute $operation1 : Operation() over window:time(60s) from entry-point "OperationStream" $operation2 : Operation(this != $operation1, ipAddress == $operation1.ipAddress) over window:time(60s) from entry-point "OperationStream" then #actions System.out.println("over-active user " + $operation1.ipAddress ); end And my JUnit test, using a PSEUDO Clock : public class DroolsRulesTestCase { static KnowledgeBase knowledgeBase; StatefulKnowledgeSession session; // FactHandle handle; SessionPseudoClock clock; WorkingMemoryEntryPoint entryPoint; private TrackingAgendaEventListener listener; private static final Logger LOGGER = Logger .getLogger(DroolsRulesTestCase.class); @BeforeClass public static void globalSetup() throws IOException { KnowledgeBuilder builder = KnowledgeBuilderFactory .newKnowledgeBuilder(); ClassPathResource classPathResource = new ClassPathResource( "rules/activity-fusion.drl"); Assert.assertTrue("Rules resource not found", classPathResource .exists()); builder.add(ResourceFactory.newInputStreamResource(classPathResource .getInputStream()), ResourceType.DRL); Assert.assertFalse("Errors in builder:" + builder.getErrors().toString(), builder.hasErrors()); KnowledgeBaseConfiguration configuration = KnowledgeBaseFactory .newKnowledgeBaseConfiguration(); configuration.setOption(EventProcessingOption.STREAM); knowledgeBase = KnowledgeBaseFactory.newKnowledgeBase(configuration); knowledgeBase.addKnowledgePackages(builder.getKnowledgePackages()); } @Before public void setup() { KnowledgeSessionConfiguration configuration = KnowledgeBaseFactory .newKnowledgeSessionConfiguration(); configuration.setOption(ClockTypeOption.get("pseudo")); session = knowledgeBase .newStatefulKnowledgeSession(configuration, null); clock = (SessionPseudoClock) session.getSessionClock(); listener = new TrackingAgendaEventListener(); session.addEventListener(listener); session.addEventListener(new TrackingWorkingMemoryEventListener()); entryPoint = session.getWorkingMemoryEntryPoint("OperationStream"); } @SuppressWarnings("unchecked") @Test public void testActivity() throws IOException, ParseException, InterruptedException { // parse the log file Resource logFile = new ClassPathResource( "activity/extract.log"); // converter and inject tracks in the session, List<String> logLines = FileUtils.readLines(logFile.getFile(), "UTF-8"); // fire all rules session.fireAllRules(); LOGGER.info("loading events"); // load events from stream for (String logLine : logLines) { Operation operation = LineConverterUtil.getOperation(logLine); LOGGER.debug("Inserting " + operation); LOGGER.debug("Moving clock from " + (new Date(clock.getCurrentTime())).toString() + " to " + operation.getDate()); clock.advanceTime(operation.getDate().getTime() - clock.getCurrentTime(), TimeUnit.MILLISECONDS); // clock.advanceTime(10, TimeUnit.SECONDS); FactHandle operationHandle = entryPoint.insert(operation); LOGGER.debug("Insertion done: " + operationHandle.toExternalForm()); } LOGGER.info("done with events"); // check... Assert.assertTrue("Rule not fired...", listener .isRuleFired("overActivity")); } } I also use a TrackingWorkingMemoryEventListener to track events. The test because since the rule is not fired, and the log contains the following lines : Console> 2010-05-17 11:15:15|INFO ||DroolsRulesTestCase.testActivity|loading events Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Inserting Operation [date=Fri Apr 30 18:26:47 CEST 2010, executionTime=1, hostname=server1, ipAddress=1.2.3.4, operation=null, requestSize=0, responseSize=0] Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Moving clock from Thu Jan 01 01:00:00 CET 1970 to Fri Apr 30 18:26:47 CEST 2010 Console> 2010-05-17 11:15:15|WARN ||TrackingWorkingMemoryEventListener.objectInserted|Object inserted: [event fid:1:1:Operation [date=Fri Apr 30 18:26:47 CEST 2010, executionTime=1, hostname=server1, ipAddress=1.2.3.4, operation=null, requestSize=0, responseSize=0]] Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Insertion done: [event fid:1:1:Operation [date=Fri Apr 30 18:26:47 CEST 2010, executionTime=1, hostname=server1, ipAddress=1.2.3.4, operation=null, requestSize=0, responseSize=0]] Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Inserting Operation [date=Fri Apr 30 18:27:11 CEST 2010, executionTime=164, hostname=server1, ipAddress=1.2.3.4, operation=CONSULTATION, requestSize=1299, responseSize=895] Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Moving clock from Fri Apr 30 18:26:47 CEST 2010 to Fri Apr 30 18:27:11 CEST 2010 Console> 2010-05-17 11:15:15|WARN ||TrackingWorkingMemoryEventListener.objectRetracted|Object retracted: [event fid:1:1:Operation [date=Fri Apr 30 18:26:47 CEST 2010, executionTime=1, hostname=server1, ipAddress=1.2.3.4, operation=null, requestSize=0, responseSize=0]] Console> 2010-05-17 11:15:15|WARN ||TrackingWorkingMemoryEventListener.objectInserted|Object inserted: [event fid:2:2:Operation [date=Fri Apr 30 18:27:11 CEST 2010, executionTime=164, hostname=server1, ipAddress=1.2.3.4, operation=CONSULTATION, requestSize=1299, responseSize=895]] Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Insertion done: [event fid:2:2:Operation [date=Fri Apr 30 18:27:11 CEST 2010, executionTime=164, hostname=server1, ipAddress=1.2.3.4, operation=CONSULTATION, requestSize=1299, responseSize=895]] Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Inserting Operation [date=Fri Apr 30 18:28:47 CEST 2010, executionTime=1, hostname=server1, ipAddress=1.2.3.4, operation=null, requestSize=0, responseSize=0] Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Moving clock from Fri Apr 30 18:27:11 CEST 2010 to Fri Apr 30 18:28:47 CEST 2010 Console> 2010-05-17 11:15:15|WARN ||TrackingWorkingMemoryEventListener.objectRetracted|Object retracted: [event fid:2:2:Operation [date=Fri Apr 30 18:27:11 CEST 2010, executionTime=164, hostname=server1, ipAddress=1.2.3.4, operation=CONSULTATION, requestSize=1299, responseSize=895]] Console> 2010-05-17 11:15:15|WARN ||TrackingWorkingMemoryEventListener.objectInserted|Object inserted: [event fid:3:3:Operation [date=Fri Apr 30 18:28:47 CEST 2010, executionTime=1, hostname=server1, ipAddress=1.2.3.4, operation=null, requestSize=0, responseSize=0]] Console> 2010-05-17 11:15:15|DEBUG||DroolsRulesTestCase.testActivity|Insertion done: [event fid:3:3:Operation [date=Fri Apr 30 18:28:47 CEST 2010, executionTime=1, hostname=server1, ipAddress=1.2.3.4, operation=null, requestSize=0, responseSize=0]] Console> 2010-05-17 11:15:15|INFO ||DroolsRulesTestCase.testActivity|done with events I guess there is something wrong with my use of the PseudoClock, since previous operations are retracted before a new one is inserted, which I believe prevents the rule to be fired. Can you help me ? Thank you in advance Regards, Xavier -- View this message in context: http://drools-java-rules-engine.46999.n3.nabble.com/Drools-Fusion-Can-t-d... Sent from the Drools - User mailing list archive at Nabble.com. _______________________________________________ rules-users mailing list rules-users(a)lists.jboss.org https://lists.jboss.org/mailman/listinfo/rules-users