Hi Wolfgang, this is an extract of drl file: declare GasObservation @role(event) @startTimestamp(timestamp) @expires( 10s ) @duration(duration) end declare GasEvent @startTimestamp(timestampDate) @role(event) @duration(duration) end rule "gas1-event" no-loop when $obs : GasObservation( $obsLocation : location, gasname == "UN 1017", value > 60 ) over window:length(1) from entry-point lowLevelSensorStream not GasEvent( location geoIsWithinDistance[ 5m ] $obsLocation, gasname == "UN 1017", this before[1s, 25s] $obs ) then insert(new GasEvent( $obs, "UN 1017 value > threshold[60]", Event.THREAT_HIGH, $obsLocation, $obs.getSensor())); end rule "gas1-event-update" no-loop when $obs : GasObservation( $obsLocation : location, gasname == "UN 1017", value > 60 ) over window:length(1) from entry-point lowLevelSensorStream $event : GasEvent( location geoIsWithinDistance[ 5m ] $obsLocation, gasname == "UN 1017", this before[1s, 25s] $obs ) then modify($event) { updateDuration(), addObservation($obs) } end and these are abstract Observation class and abstract Event public abstract class Observation implements Serializable { /** * */ private static final long serialVersionUID = 3483256523801072709L; private long timestamp; private long duration; private Geometry location; private Sensor sensor; public long getTimestamp() { return timestamp; } public void setTimestamp(long timestamp) { this.timestamp = timestamp; } public long getDuration() { return duration; } public void setDuration(long duration) { this.duration = duration; } public Sensor getSensor() { return sensor; } public void setSensor(Sensor sensor) { this.sensor = sensor; } public Geometry getLocation() { return location; } public void setLocation(Geometry location) { this.location = location; } /** * @param newTimeStamp * this methods allows to update the duration of event by setting the timestamp of new observation. */ public void updateDuration(long newTimeStamp) { setDuration(newTimeStamp - getTimestamp()); } public Date getTimestampDate() { return new Date(timestamp); } public void setTimestampDate(Date timestamp) { this.timestamp = timestamp.getTime(); } public Observation(Sensor sensor, Geometry location, long timestamp) { this.setLocation(location); this.setTimestamp( timestamp ); this.setSensor( sensor ); } /** * @return identification by servicename:timestamp */ public String getServiceIdentification() { return getSensor().getServiceName() + ":" + getTimestamp() ; } } public abstract class Event implements Serializable { ..... /** * */ private static final long serialVersionUID = 1L; /** * The timestamp of event. */ private long timestamp; /** * The level of threat of the event. */ private int threat_level; /** * The description of event. */ private String description; /** * The location of event. */ private Geometry location; /** * Duration of event. */ private long duration; /** * Id of sensor. */ private Sensor sensor; /** * The map feature involved into Event. */ private MapFeature feature; /** * link to the timestamp of parent event. */ private long parent; private Collection<Observation> observations; private Collection<Event> relatedEvents; public abstract int getType(); public Collection<Observation> getObservations() { return observations; } public void addObservation(Observation obs) { observations.add(obs); } public Collection<Event> getRelatedEvents() { return relatedEvents; } public void addRelatedEvent(Event evnt) { relatedEvents.add(evnt); } public Sensor getSensor() { return sensor; } public void setSensor(Sensor sensorId) { this.sensor = sensorId; } public long getDuration() { return duration; } public void setDuration(long duration) { this.duration = duration; } public int getThreat_level() { return threat_level; } public void setThreat_level(int threatLevel) { threat_level = threatLevel; } /** * @param newTimeStamp * this methods allows to update the duration of event by setting the timestamp of new observation. */ public void updateDuration() { setDuration(System.currentTimeMillis() - getTimestamp()); } public long getTimestamp() { return timestamp; } public void setTimestamp(long timestamp) { this.timestamp = timestamp; } public Date getTimestampDate() { return new Date(timestamp); } public void setTimestampDate(Date timestamp) { this.timestamp = timestamp.getTime(); } public String getDescription() { return description; } public void setDescription(String description) { this.description = description; } public Geometry getLocation() { return location; } public void setLocation(Geometry location) { this.location = location; } /* public int getType() { return type; } public void setType(int type) { this.type = type; } */ public MapFeature getFeature() { return feature; } public void setFeature(MapFeature feature) { this.feature = feature; } public long getParent() { return parent; } public void setParent(long timestamp) { parent = timestamp; } /** * @param description description of event * @param threat_level threat level of timestamp * @param location location of event * @param sensor sensor related to this event * @param feature map feature related to event */ protected Event(String description, int threat_level, Geometry location, Sensor sensor, MapFeature feature) { this.setTimestamp(System.currentTimeMillis()); this.observations = new ArrayList<Observation>(); this.relatedEvents = new ArrayList<Event>(); this.setTimestamp( timestamp ); this.setDescription( description ); this.setThreat_level( threat_level ); this.setLocation( location ); this.setSensor(sensor); this.setFeature( feature ); } public String getServiceIdentification() { return "events:" + this.timestamp; } } Thanks a lot in advance. 2012/2/22 Wolfgang Laun <wolfgang.laun(a)gmail.com&gt;

Hi Edson, so, when i want modify an event, i could do as follow: - clone event; - change the duration - retract the previuos event - insert the new event Is it right? Bye bye, Matteo. 2012/2/22 Edson Tirelli <ed.tirelli(a)gmail.com&gt;

On 22/02/2012, Edson Tirelli <ed.tirelli(a)gmail.com&gt; wrote: But mind the requirements of STREAM mode: Events in each stream must be time-ordered. I.e., inside a given stream, events that happened first must be inserted first into the engine. If reinsertions would violate this, you must run the session in CLOUD mode, which has certain consequences. This is all very well described in the Fusion manual, section on "Event Processing Modes". -W

A couple comments: * The temporal reasoning features/operators are available in both CLOUD and STREAM mode. The biggest differences are that in CLOUD mode there is no automatic garbage collection of old events and you can't use sliding windows, but everything else works. * You can insert events with old timestamps, but in that case it is the rule's author responsibility to understand that sliding windows using that event type might be affected and if running in STREAM mode, you should define an expiration policy for that event type that will keep him in memory for enough time to match any rules that require it. For instance, if in your application events will have a maximum duration of 24hs and because of that they can be inserted into the system with a delay of 24hs, you should define an expiration policy for it that is at least 24hs. Edson 2012/2/24 Matteo Cusmai <cusmaimatteo(a)gmail.com&gt; -- Edson Tirelli JBoss Drools Core Development JBoss by Red Hat @ www.jboss.com