初始化 Drools 和 kiesession 时,一切正常。
kieSession.insert(Event) [this is a CEP app]效果很好,但我无法初始化入口点。
EntryPoint ep = kieSession.getEntryPoint("My EntryPoint")总是返回 NULL。
是否有必要以某种方式初始化入口点?我的结论是我的 kiSession 没有一个名为“MyEntryPoint”的入口点,并且 getEntryPoint() 没有创建它,所以它总是返回 NULL。
KieServices kieServices = KieServices.Factory.get();
// Load KieContainer from resources on classpath (i.e. kmodule.xml and rules).
KieContainer kieContainer = kieServices.getKieClasspathContainer();
KieBaseConfiguration config = kieServices.newKieBaseConfiguration();
config.setOption(EventProcessingOption.STREAM);
// Initializing KieSession.
LOGGER.info("Creating KieSession.");
kieSession = kieContainer.newKieSession("ksession-rules");
kieSession.addEventListener(new DebugEventListener());
// Collection<KiePackage> x = kieSession.getKieBase().getKiePackages();
DroolsActionHandler drlActionHandler = new DroolsActionHandler();
// kieSession.insert(drlActionHandler);
kieSession.setGlobal("drlActionHandler", drlActionHandler);
samplingStream = kieSession.getEntryPoint("StufaSampingStream");
<kmodule xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.drools.org/xsd/kmodule">
<kbase name="rules" equalsBehavior="equality" eventProcessingMode="stream" default="true" packages="resources.rules.actuators">
<ksession name="ksession-rules" default="true" type="stateful" clockType="pseudo">
<!-- <fileLogger file="/var/log/sintechs/drools" threaded="true" interval="10"/> -->
</ksession>
</kbase>
</kmodule>
采样流总是返回Null。