[rules-users] counter in slidingTime window with restriction

[Alexander Wolf]

Drools Version 5.5.0 FINAL

Here's the code for session setup:

        KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
        kbuilder.add(ResourceFactory.newClassPathResource("myrule.drl"), ResourceType.DRL);
        
        // Check the builder for errors
        if (kbuilder.hasErrors()) { System.out.println(kbuilder.getErrors().toString());
        	throw new RuntimeException("Unable to compile \"myrule.drl\".");
        }
        
        KnowledgeBase kbase = kbuilder.newKnowledgeBase();
        //configure knowledge base
        KnowledgeBaseConfiguration baseConfig = KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
        baseConfig.setOption( EventProcessingOption.STREAM );
        
        //init session clock
        KnowledgeSessionConfiguration sessionConfig = KnowledgeBaseFactory.newKnowledgeSessionConfiguration();
        sessionConfig.setOption( ClockTypeOption.get("realtime") );
        //init stateful knowledge session
        StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession(sessionConfig, null);


And here's how I inserted the events for testing purpose:


    	//get Knowledge Base
    	StatefulKnowledgeSession ksession = initKnowledgeSession();
    	
        //entry point for sensor events
        WorkingMemoryEntryPoint sensorEventStream = ksession.getWorkingMemoryEntryPoint( "SensorEventStream" );
        
        Room room = new Room(24);
        ksession.insert(room);
        System.out.println("1. fireAllRules()");
        ksession.fireAllRules();
        //insert events
        for(int i=2;i<8;i++){
        	SensorEvent event = new SensorEvent("inc" + (i-1));
        	sensorEventStream.insert( event );

        	System.out.println(i + ". fireAllRules()");
        	ksession.fireAllRules();
        	Thread.sleep(1005);
        }
        
	//let thread sleep for another 1m to see if dereffered rules fire (timers, (not) after rules)
        Thread.sleep(1000*60*1);
        
        ksession.dispose();
 


On 05.09.2013, at 12:02, Wolfgang Laun <wolfgang.laun at gmail.com> wrote:

> Hard to believe, but who knows.
> 
> Drools version and session setup, please.
> 
> -W
> 
> 
> On 05/09/2013, Alexander Wolf <mail at alexander-wolf.net> wrote:
>> Hey guys,
>> 
>> I wrote a rule to count the SensorEvents in my KnowledgeSession that have
>> been inserted via entry-point SensorEventStream over the last 3 seconds -
>> but I only want the event to fire, if there were any events in the last 3
>> seconds at all.
>> 
>> Problem: if there were no recent events, i still get the output:
>> 
>>> Events in last 3 seconds: 0
>> 
>> I don't really get why?! This is my rule code:
>> 
>> 
>> rule "slidingTimeCount"
>> when
>> 	$n: Number (intValue > 0) from accumulate ( $e: SensorEvent() over
>> window:time(3s) from entry-point SensorEventStream, count($e))
>> then
>> 	System.out.println("Events in last 3 seconds: " + $n);
>> end
>> 
> _______________________________________________
> rules-users mailing list
> rules-users at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users

-------------- next part --------------
A non-text attachment was scrubbed...
Name: signature.asc
Type: application/pgp-signature
Size: 841 bytes
Desc: Message signed with OpenPGP using GPGMail
Url : http://lists.jboss.org/pipermail/rules-users/attachments/20130906/c5dca3fe/attachment.bin