Hello,
I've got the following basic code that sets up drools in STREAM mode, with a
pseudo clock.
And it fails on the last line that asserts there is an entrypoint named
"testEntryPoint".
The DRL file references the entry-point which according to the documentation is
enough.
What am I missing?
Itai
declare Message
@role(event)
@timestamp(timestamp)
end
declare AppInfo
@role(event)
@timestamp(timestamp)
end
rule "Change message type after one minute"
dialect "mvel"
when
$appinfo:AppInfo() from entry-point "testEntryPoint"
$message:Message( type == "before", $msgtext : msgtext, this after[ 1m ]
$appinfo )
from entry-point "testEntryPoint"
then
System.out.println( $msgtext );
modify ( $message ) {
type = "after"
}
end
private void initDrools() {
KnowledgeBaseConfiguration config =
KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
// Stream mode allows interacting with the clock (Drools Fusion)
config.setOption(EventProcessingOption.STREAM);
kbase = KnowledgeBaseFactory.newKnowledgeBase(config);
kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
// this will parse and compile in one step
kbuilder.add(ResourceFactory.newClassPathResource(RULE_FILE,
DroolsExpertTest.class), ResourceType.DRL);
// Check the builder for errors
assertThat(kbuilder.hasErrors())
.overridingErrorMessage(kbuilder.getErrors().toString())
.isFalse();
// get the compiled packages (which are serializable)
Collection<KnowledgePackage> pkgs = kbuilder.getKnowledgePackages();
// add the packages to a knowledgebase (deploy the knowledge packages).
kbase.addKnowledgePackages(pkgs);
KnowledgeSessionConfiguration conf =
KnowledgeBaseFactory.newKnowledgeSessionConfiguration();
conf.setOption(ClockTypeOption.get("pseudo"));
ksession = kbase.newStatefulKnowledgeSession(conf,null);
clock = ksession.getSessionClock();
entryPoint = ksession.getWorkingMemoryEntryPoint("testEntryPoint");
assertThat(entryPoint).isNotNull();
}
_______________________________________________
rules-users mailing list
rules-users@lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
