[rules-users] Drools Fusion Dropping Actions to Events?

[chandu_divi]

I am using Drools Fusion 6.0.1.Final version, it looks like some (rather
several) actions to the events are dropped. I am sending about 100K events
and expecting an action to all the events, but only 5000 actions are
performed, which means about 95K actopms are dropped.

The same issue was posted in the thread
http://drools.46999.n3.nabble.com/rules-users-Drools-Fusion-Dropping-Events-td4023843.html,
but it is marked as resolved.

The defect https://issues.jboss.org/browse/DROOLS-131 is also marked as
fixed.

But this issue seems to be appearing again.

Here is my code.

kmodule.xml

<?xml version="1.0" encoding="UTF-8"?>
<kmodule xmlns="http://jboss.org/kie/6.0.0/kmodule">
    <kbase name="eventDrop" packages="ed" eventProcessingMode="stream">
        <ksession name="edSession"/>
    </kbase>
</kmodule>

ed.drl

package drools

import foo.TemperatureEvent

declare TemperatureEvent
@role(event)
end

rule "RULE S1"
when
    $te:TemperatureEvent(measure <= 50) from entry-point entryone
then
    System.err.println("The temperature at location - "+$te.getLocation() +
" is " + $te.getMeasure());
end

rule "RULE S2"
when
    $te:TemperatureEvent(measure > 50) from entry-point entryone
then
    System.err.println("The temperature at location - "+$te.getLocation() +
" is " + $te.getMeasure());
end


TemperatureEvent.java

package foo;

public class TemperatureEvent {

    int measure;
    String location;
    long timeStamp;

    public TemperatureEvent(int measure, String location, long timeStamp) {
        this.measure = measure;
        this.location = location;
        this.timeStamp = timeStamp;
    }

    public int getMeasure() {
        return measure;
    }

    public void setMeasure(int measure) {
        this.measure = measure;
    }

    public String getLocation() {
        return location;
    }

    public void setLocation(String location) {
        this.location = location;
    }

    public long getTimeStamp() {
        return timeStamp;
    }

    public void setTimeStamp(long timeStamp) {
        this.timeStamp = timeStamp;
    }
}

App.java

package foo;

import java.io.FileOutputStream;
import java.io.PrintStream;
import java.util.Random;

import org.kie.api.KieServices;
import org.kie.api.runtime.KieContainer;
import org.kie.api.runtime.KieSession;
import org.kie.api.runtime.rule.EntryPoint;

public class App {
    public static void main(String[] args) throws Exception {
        System.setErr(new PrintStream(new FileOutputStream("report.txt")));
        // Start Drools.
        KieServices ks = KieServices.Factory.get();
        KieContainer kContainer = ks.getKieClasspathContainer();
        final KieSession kSession = kContainer.newKieSession("edSession");
        EntryPoint entryPoint1 = kSession.getEntryPoint("entryone");

        new Thread() {
            @Override
            public void run() {
                kSession.fireUntilHalt();
            }
        }.start();

        Random measure = new Random(System.currentTimeMillis());
        Random location = new Random(System.currentTimeMillis() - 1000000L);
        String locations[] = { "Bangalore", "Chennai", "Delhi", "Mumbai",
"Kolkata" };
        for (int i = 0; i < 10; ++i) {
            for (int j = 0; j < 1000; ++j) {

                TemperatureEvent te = new TemperatureEvent(
                        measure.nextInt(100),
locations[location.nextInt(5)],
                        System.currentTimeMillis());
                entryPoint1.insert(te);
//                Thread.sleep(1);
            }
        }
        Thread.sleep(100);
        kSession.halt();
        kSession.dispose();
    }
}





--
View this message in context: http://drools.46999.n3.nabble.com/Drools-Fusion-Dropping-Actions-to-Events-tp4029314.html
Sent from the Drools: User forum mailing list archive at Nabble.com.