package org.example.drools;
import org.example.drools.DispatchEvent;
global java.util.List results;

rule "Rule1"
when
    $e : DispatchEvent($id : id) from entry-point "events"
then
    results.add("received event: " + $id);
    System.out.println("received event: " + $id);
end 

EntryPoint events = session.getEntryPoint("events");
Executors.newSingleThreadExecutor()
        .submit(() -> {
            try {
                System.out.println("fire until halt...");
                session.fireUntilHalt();
            } catch (Throwable e) {
                e.printStackTrace(System.err);
            }
        });

sleep(1000);

System.out.println("insert event aaa");
events.insert(new DispatchEvent("aaa"));
//sleep(100);

System.out.println("insert event bbb");
events.insert(new DispatchEvent("bbb"));
//sleep(100);

System.out.println("halt...");
session.halt();
sleep(1000); 

fire until halt...
insert event aaa
insert event bbb
halt...
received event: aaa