[jboss-jira] [JBoss JIRA] (DROOLS-747) declared window, type length, do actually contain more than 1 object (with reteoo)
Matteo Mortari created DROOLS-747:
-------------------------------------
Summary: declared window, type length, do actually contain more than 1 object
(with reteoo)
Key: DROOLS-747
URL: https://issues.jboss.org/browse/DROOLS-747
Project: Drools
Issue Type: Bug
Components: core engine
Affects Versions: 6.2.0.Final
Reporter: Matteo Mortari
Assignee: Mario Fusco
h5. Premise
I know reteoo is progressively being deprecated, but I think until is there is helpful for
A/B testing of possible leaks comparing with phreak (like it happened during 610Final) so
reporting this bug.
h5. Executive summary
Declaring a window of type length (1) should always contain 1 object.
h5. Details
With reference to attached reproducer.
Given the following knowledge base:
{code}
global java.util.concurrent.atomic.AtomicLong globalCounter;
declare Measurement
@role(event)
end
declare window lastMeasurement
Measurement() over window:length( 1 ) // from entry-point DEFAULT
end
rule "IFF the last Measurement that I know of, is of ID color, increment the
counter"
no-loop
when
Measurement( id == "color" ) from window lastMeasurement
then
globalCounter.incrementAndGet();
end
{code}
The goal is: IFF the last Measurement that I know of, is of ID "color",
increment the counter. Please notice you ought to separate the window being just on
Measurement, in order to know the last Measurement regardless of the ID, and then you have
a rule acting on the declared window, to check IFF this last Measurement, is actually of
ID "color".
Now assuming you just have created the session and the following increment/insert/fire:
{code}
AtomicLong globalCounter = new AtomicLong(0);
session.setGlobal("globalCounter", globalCounter);
session.fireAllRules();
assertEquals("no data, still 0", 0, globalCounter.get());
LOG.info("Now running data");
clock.advanceTime(1, TimeUnit.MINUTES);
Measurement mRed= new Measurement("color", "red");
session.insert(mRed);
Measurement mGreen= new Measurement("color", "green");
session.insert(mGreen);
Measurement mBlue= new Measurement("color", "blue");
session.insert(mBlue);
session.fireAllRules();
LOG.info("Final checks");
assertEquals("win lenght =1 was: ", 1, globalCounter.get());
{code}
At the end you should have the global counter with value = 1, because we inserted 3 events
of type Measurement, but the declared window lastMeasurement should reference only
{{mBlue}}, which should be later picked by the rule because the ID is "color",
and increment the counter by 1.
This works with phreak, it does not work with reteo.
phreak globalCounter = 1 : OK
reteoo globalCounter = 3 : FAIL.
Could you kindly advise, please?
Thanks
--
This message was sent by Atlassian JIRA
(v6.3.11#6341)