Hi all,
i am going to use a custom accumulate function like that:
rule "CrowdInAreaEvent-event"
no-loop
when
$RFIDReader : SensorFixed(type == Sensor.SENSOR_TYPE_RFID,
$coverageArea : areaOfInterest )
not CrowdInAreaEvent( sensor == $RFIDReader, this meets[ 5s ] $obs )
$count : Integer( intValue > 10 )
from accumulate( $obs : RFIDObservation( $tagid : tagid, sensor
== $RFIDReader )
over window:time( 60s ) from entry-point lowLevelSensorStream,
countDistinct( $tagid ) );
then
insert( SituationManager.createCrowdInAreaEvent( "Crowd, number
people: " + $count, Event.THREAT_LOW, $coverageArea, $RFIDReader, $count,
60, 10 ) );
end
I need to refer $obs object in order to compare timing of new observation
with last event. Is it possible to do that?
Thanks a lot,
Matteo.