[rules-users] Drools 6.0.1 CEP stucks during marshaling in fireUntilHalt mode
Hi drools experts.
We use drools fusion complex event processor (CEP). After migration from
5.4.0 to 6.0.1 I encountered a problem - CEP stucks during marshaling in
fireUntilHalt mode. Below self-contained reproducer.
--------------------------------
/*Event class:*
/public class Test1 {
private Date timestamp;
private String id;
}/
/*Rule drl:*
/package bpmn;
import com.test.event.*;
dialect "mvel"
declare BusinessProcessName
name : String;
end
declare com.test.event.Test1
@role( event )
end
rule "Insert Business Process Name"
salience 10
when
not BusinessProcessName(name == "SomeName")
then
System.out.println("Insert Business Process Name");
insert(new BusinessProcessName("SomeName"));
end
rule "Start event1"
when
$event1 : Test1()
then
System.out.println("Start event1 fired.");
end/
/*Test with whole initialization*
/public class TestDrools6CEPDeadLock implements RuleRuntimeEventListener {
private KieSession ksession;
private Marshaller marshaller;
@Test
public void test1() throws Exception {
initSession();
runFireUntilHaltThread();
System.out.println("-= 1 =-");
ksession.insert(new Test1());
System.out.println("-= 2 =-");
ksession.insert(new Test1());
}
private void runFireUntilHaltThread() {
new Thread(new Runnable() {
public void run() {
ksession.fireUntilHalt();
}
}).start();
}
private void initSession() {
KnowledgeBuilder kbuilder =
KnowledgeBuilderFactory.newKnowledgeBuilder();
kbuilder.add(ResourceFactory.newClassPathResource("TestDrools6CEPDeadLock.drl"),
ResourceType.DRL);
if (kbuilder.hasErrors()) throw new RuntimeException("Unable to
compile drl\".");
KieBaseConfiguration config =
KieServices.Factory.get().newKieBaseConfiguration();
config.setOption(EventProcessingOption.STREAM);
KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase(config);
kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
ksession = kbase.newKieSession();
ksession.addEventListener((RuleRuntimeEventListener) this);
marshaller = MarshallerFactory.newMarshaller(kbase);
}
@Override
public void objectInserted(ObjectInsertedEvent event) {
System.out.println("------------------objectInserted---------------");
marshallSession();
}
@Override
public void objectUpdated(ObjectUpdatedEvent event) {
System.out.println("------------------objectUpdated---------------");
marshallSession();
}
@Override
public void objectDeleted(ObjectDeletedEvent event) {
System.out.println("------------------objectDeleted---------------");
marshallSession();
}
private void marshallSession() {
try {
marshaller.marshall(new ByteArrayOutputStream(), ksession);
System.out.println("------------------marshalled---------------");
} catch (IOException e) {
e.printStackTrace();
}
}
}/
*Output *of test I see only:
-= 1 =-
------------------objectInserted---------------
Insert Business Process Name
Further engine hangs up, looks like dead lock on
ProtobufOutputMarshaller.evaluateRuleActivations() (line 256) >
RuleExecutor.reEvaluateNetwork().
Notes:
1) It worked fine on 5.4.0.Final version
2) Current problem not occurs if I run fireAllRules in second thread instad
of filreUntilHalt
private void runFireAllRulesInThread() {
new Thread(new Runnable() {
public void run() {
while(true){
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
LOG.error(e);
}
synchronized (ksLock){
ksession.fireAllRules();
}
}
}
}).start();
}
I need this thread to ensure firing timing rules such like:
$event1 : Test1();
not Test2(this after[0s, 10s ] $event1 );
I hope this can help to resolve either my or drools bug.
Thanks in advance.
--
View this message in context:
http://drools.46999.n3.nabble.com/Drools-6-0-1-CEP-stucks-during-marshali...
Sent from the Drools: User forum mailing list archive at Nabble.com.